Github user glaksh100 commented on the issue:
https://github.com/apache/flink/pull/5860
@fhueske I gave it some thought and your suggestion makes sense to me. I
have extended `checkForInactiveBuckets` to include the rollover check. I have
also updated Javadocs in a few places:
- Added a note in the top-level Javadocs to update functionality of
`checkForInactiveBuckets()`
- Updated JavaDocs for both `setBatchRolloverInterval()` and
`setInactiveBucketThreshold()`
- Updated JavaDoc for `checkForInactiveBuckets()`
Let me know if the updates make sense and thank you for reviewing!
---
