If there is a "’Sink: Unnamed" operator using pure SQL, I think we should improve this to give a meaningful operator name.
On Tue, 4 Aug 2020 at 21:39, godfrey he <godfre...@gmail.com> wrote: > 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 >> >> >>