Github user dubin555 commented on the issue: https://github.com/apache/flink/pull/5202 Hi @sunjincheng121 , thanks for the overall review of my code. I've done some typo fix and add some test case base on your comment. Really appreciate for your careful review! Du Bin
---