Hi Congxian, It is not the same with Idling Source
Best Ocean Congxian Qiu <qcx978132...@gmail.com> 于2019年12月24日周二 下午4:39写道： > > 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 > > > > > >
