Github user NicoK commented on the issue:
https://github.com/apache/flink/pull/5317
@zhijiangW can you rebase the new changes? The previous implementation got
merged and from the comments I see here, there might have been some changes
since then which should be applied as well.---
