Hi Maybe the doc[1] about Idling Source can help there. [1] https://ci.apache.org/projects/flink/flink-docs-stable/dev/event_time.html#idling-sources
Best, Congxian Jocean shi <jocean....@gmail.com> 于2019年12月24日周二 下午3:05写道： > Hi Jark, > > I got you. We have discussed this question in Flink Forward 2019. > I know that i can custom operator to resolve this problem. > but also has some other problems: > > First, > This is a very common scene that we often meet > I have to rewrite "BroadcastConnectedStream","ConnectedStreams" ... > and "TwoInputStreamOperator" and rewrite "SingleOutputStreamOperator" > bucause it's "protected", > It's unfriendly for new user. > > Second. > One stream even don't call "assignTimestampsAndWatermarks" method, > It's mean this stream don't have time and watermark, > It don't have time and watermark why It have a hand in computing of > watermak and time default. > > Best > Jark > > Jark Wu <imj...@gmail.com> 于2019年12月24日周二 下午12:08写道： > > > > 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 > > > >
