Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/5480
I see, so it is basically a quicker workaround for per-shard watermarks for
the Kinesis Consumer.
Since we discussed that we'll likely have a reworked consumer in 1.6 that
hopefully includes per-shard watermarks, I'll agree to merge this temporary
workaround change now for 1.5.---
