向flink提交自定义任务，启动的时候正常连接，但是一旦提交任务就报错退出了，是什么原因呢？

在本地跑是正常的，但是部署到线上后，一旦提交任务就报错退出了。并且因为maprduce任务开始的时候是正常的，因此yarn上的日志也没有错误日志。只有控制台中的这一些提示。pom文件中所有依赖都加上了provided。但是一旦提交任务就退出了socket连接，重复了很多次都这样

源自：Flink快速上手篇 3-3 向集群中提交Flink任务

收起

1回答

徐老师 2023-10-18 19:31:24

需要先启动socket，再提交任务，否则任务提交上去连不上socket就异常退出了

提问者蒋昌魁 #1
奥，老师，我知道我这里是什么原因了，目前安装的flink比较新，按照网上提示的加入这条语句就不会报错了
```
env.setStreamTimeCharacteristic(TimeCharacteristic.ProcessingTime)
```
那老师目前的版本窗口函数该怎么使用呢？因为我发现
```
env.setStreamTimeCharacteristic(TimeCharacteristic.ProcessingTime)
```
这个语句也被提示已过期，不推荐使用了
2023-10-18 21:35:31
徐老师回复提问者蒋昌魁 #2

学习阶段建议使用flink1.11版本，flink版本迭代较快，api变化也比较大，后面会遇到很多这种发生变化的问题。课程后面也提供的有flink1.15版本的使用，所以现在学习前面的建议使用课程中的版本

2023-10-18 21:37:51