I did some more testing.
Below is a pseudo version of by setup.
But print2 is always Long.MIN
Now, if I run the exact same code on a flink cluster, print2 outputs expected watermark.
From: Fabian Hueske <fhueske@xxxxxxxxx>
Watermarks cannot make progress if you have stream partitions that do not carry any data.
What kind of source are you using?
2018-08-15 4:25 GMT+02:00 vino yang <yanghua1127@xxxxxxxxx>: