flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From John O <son...@samsung.com>
Subject watermark does not progress
Date Wed, 15 Aug 2018 01:44:10 GMT
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(BoundedOutOfOrdernessTimestampExtractor) ...

Also, configured the environment as so
env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime)

If I run the job on a flink cluster, I do see the watermark progress.

Is watermarking not supported in local mode?

Thanks
Jo

Mime
View raw message