@yanghua I found more issues related to this topic when testing your code. I fixed it in #6671. What do you think about this changes?
[ Full content available at: https://github.com/apache/flink/pull/6659 ] This message was relayed via gitbox.apache.org for [email protected]
