Github user twalthr commented on the issue: https://github.com/apache/flink/pull/5174 Thanks for the PR @Xpray and the review @walterddr. I also looked over the changes and saw multiple issues that need to be fixed. If it is ok for you, I would add some commits to this one and open a new PR in order to get the fix into 1.5.
---