Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/4747 This looks very good, the test is also much cleaner and understandable now. ð One thing, in the refactoring the bit of testing code that verifies the fix for FLINK-7721 was dropped (I checked this by commenting out the fix in the code). I'll re-add a test for that and merge.
---