Hi Jingsong, Thanks for your input. Now I understand the design.
I think in my case the StreamingFileCommitter is not chained because its upstream operator is not parallelism 1. BTW, it’d be better if it has a more meaningful operator name. Best, Paul Lam > 2020年8月4日 17:11,Jingsong Li <jingsongl...@gmail.com> 写道: > > StreamingFileCommitter