Details
-
Improvement
-
Status: Reopened
-
Not a Priority
-
Resolution: Unresolved
-
1.10.0
-
None
-
None
Description
During the review of https://github.com/apache/flink/pull/11061
the following issue was discovered by kkl0u :
Here shouldn't we restart the timer? It seems like we may be in the situation where we flushed this batch because we reached the max size, so for the new one we have to set a new timer (renew the BatchIntervalMs), right?