Github user zhijiangW commented on the issue:
https://github.com/apache/flink/pull/4559
@NicoK , thanks for your reviews and I have updated the codes for above
comments.
Regarding the tests for backlog statistics, do you think I should add new
tests in this PR or update your added tests later after your commit is merged?---
