Re: Slow watermark advances

2018-04-13 Thread Xingcan Cui
mechanism. > > As a workaround, you could try to add (or subtract) a static time offset to > one of your streams, which can make them more “close” to each other. > > Best, > Xingcan > > >> On 13 Apr 2018, at 11:48 PM, Chengzhi Zhao > <mailto:w.zhaocheng.

Re: Slow watermark advances

2018-04-13 Thread Chengzhi Zhao
an make them more “close” to each other. > > Best, > Xingcan > > > On 13 Apr 2018, at 11:48 PM, Chengzhi Zhao > wrote: > > Hi, flink community, > > I had an issue with slow watermark advances and needs some help here. So > here is what happened: I have two stream

Re: Slow watermark advances

2018-04-13 Thread Xingcan Cui
time offset to one of your streams, which can make them more “close” to each other. Best, Xingcan > On 13 Apr 2018, at 11:48 PM, Chengzhi Zhao wrote: > > Hi, flink community, > > I had an issue with slow watermark advances and needs some help here. So here > is what ha

Slow watermark advances

2018-04-13 Thread Chengzhi Zhao
Hi, flink community, I had an issue with slow watermark advances and needs some help here. So here is what happened: I have two streams -- A and B, and they perform co-process to join together and A has another steam as output. A --> Output B --> (Connect A) --> Outpu