Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/4815
Thanks for the PR @godfreyhe.
The fix looks good, but I don't think we need three end-to-end integration
tests to check the behavior. I'll add a unit test and will remove the
integration tests before merging.---
