Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/4915
Thanks for the work and reviews @GJL @pnowojski.
I did a pass also, changes LGTM.
Left one last comment regarding the integration test class name.
Other than that, would like to merge this if there are no other objections.---
