Hi Ocean, You can implement your custom operator by the "TwoInputStreamOperator" interface. The TwoInputStreamOperator interface provides "processWatermark1" and "processWatermark2" which handles watermarks for left stream and right stream. You can then ignore the watermarks from right stream and forward watermark from left stream.
Best, Jark On Mon, 23 Dec 2019 at 21:47, Jocean shi <jocean....@gmail.com> wrote: > Hi all: > Currently, The "TwoInputStreamOperator" such as > "CoBroadcastWithKeyedOperator" "KeyedCoProcessOperator" and the > (Co)stream such as "ConnectedStreams" "BroadcastConnectedStream" only > support compute watermark by two stream. > but we just need one stream to compute watermark in some case. > For example: one stream is only rule data or control command, it > don't hava event time. > I think user has right to choose which stream to compute watermark. > > Best > Ocean >
