gt; Jo
>
>
>
>
>
>
>
> *From:* Hequn Cheng
> *Sent:* Wednesday, August 15, 2018 6:38 AM
> *To:* John O
> *Cc:* Fabian Hueske ; vino yang ;
> user
>
> *Subject:* Re: watermark does not progress
>
>
>
> Hi John,
>
>
>
> I guess the sourc
ill have to choose which watermark to use from the multiple
sources(the lowest value) thus never progressing the watermark.
Jo
From: Hequn Cheng
Sent: Wednesday, August 15, 2018 6:38 AM
To: John O
Cc: Fabian Hueske ; vino yang ; user
Subject: Re: watermark does not progress
Hi John,
I gu
t;
>
>
> Now, if I run the exact same code on a flink cluster, print2 outputs
> expected watermark.
>
>
>
> Jo
>
>
>
> *From:* Fabian Hueske
> *Sent:* Wednesday, August 15, 2018 2:07 AM
> *To:* vino yang
> *Cc:* John O ; user
> *Subject:* Re: watermark doe
watermark.
Jo
From: Fabian Hueske
Sent: Wednesday, August 15, 2018 2:07 AM
To: vino yang
Cc: John O ; user
Subject: Re: watermark does not progress
Hi John,
Watermarks cannot make progress if you have stream partitions that do not carry
any data.
What kind of source are you using?
Best,
Fab
apache-flink-user-mailing-list-archive.2336050.
> n4.nabble.com/Debugging-watermarks-td7065.html
>
> Thanks, vino.
>
> John O 于2018年8月15日周三 上午9:44写道：
>
>> I am noticing that watermark does not progress as expected when running
>> locally in IDE. It just stays at Long.MI
watermark, you can also refer to this email[1].
[1]:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Debugging-watermarks-td7065.html
Thanks, vino.
John O 于2018年8月15日周三 上午9:44写道：
> I am noticing that watermark does not progress as expected when running
> locally in I
I am noticing that watermark does not progress as expected when running locally
in IDE. It just stays at Long.MIN
I am using EventTime processing and have tried both these time extractors.
* assignAscendingTimestamps ...
*
assignTimestampsAndWatermarks
