Github user yanghua commented on the issue: https://github.com/apache/flink/pull/6134 cc @dawidwys refactored code, please review again~
---
Github user yanghua commented on the issue: https://github.com/apache/flink/pull/6134 cc @dawidwys refactored code, please review again~
---