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 > > >
