I think we assign a meaningful name to sink Transformation
 like other Transformations in StreamExecLegacySink/BatchExecLegacySink.

Paul Lam <paullin3...@gmail.com> 于2020年8月4日周二 下午5:25写道:

> 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