Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/5573
@tillrohrmann thanks for your reply, it's a misoperation, I have done
rollback and refactored the code based on your suggestion. Please check the
change again.---
