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

Reply via email to