Hi community, Now after a channel become active from idle, the watermark on this channel would not be took into account when align watermarks util it generates a watermark equals to or bigger than last emitted watermark. It makes sense because it could prevent the newly active task resumed from idle dragging down the entire job.
However, if the newly active task generate watermarks which are smaller than but very closely to the last emitted one for a long time, it could not be took into consideration in watermark alignment which may lead to its data maybe dropped at the later window operator. Is there any way to solve this problem? Or could we add a configuration to define different watermark aligned behavior？ Any suggestion is appreciated. Thanks a lot. Regards JING
