https://issues.apache.org/jira/browse/FLINK-10941 这个问题 已经在github上解决,但为合并到官方可下载的版本中,开发者可以根据思路,自己修改源码,build 替换有bug的包,这个包是我整理好的,已经在我们项目中运行一段时间了,大家不想修改源码的可以下来使用。