两种可能
第一种是程序30秒内没有做出反应导致taskmanager挂掉
解决办法 在flink-conf.yaml中配置task.cancellation.timeout: 0
第二种是任务被阻塞在某个方法里
解决办法看日志找到被阻塞的方法进行解决