Hi team, I reproduced #7458 locally and have a prototype fix. It keeps one writer per input while allowing bounded concurrency across inputs. Details are in my comment. Could someone familiar with BlockingSink take a look and let me know if this approach makes sense? Thanks!