这个应该和内存有关，我之前试过，存储的状态无限增长，导致运行几分钟后任务结束，并抛出异常，可以尝试一下加大内存和清理状态
| | 刘海 | | liuha...@163.com | 签名由网易邮箱大师定制 在2021年1月4日 11:35，咿咿呀呀<201782...@qq.com> 写道： 我按照您这个修改了，跟我之前的也是一样的。能运行的通，输出的结果也是正确的，现在最大的问题是——运行一段时间后（3分钟左右）就出现了OSError: Expected IPC message of type schema but got record batch这个错误 -- Sent from: http://apache-flink.147419.n8.nabble.com/
