Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/6206 Thanks for looking into this @zsolt-donca. The changes looks good to me, but as @yanghua mentioned, a test to cover the previous bug would be nice here and allow the reviewer to understand directly that it is a required fix.
---