初学Flink上传jar包出现报错Internal server error.---No data for required key 'port'

发布时间 2023-04-12 10:36:25作者: 丶林东方

查看Job Manager里面的日志

 

 

 发现错误,java.lang.RuntimeException: No data for required key 'port'

 

 

 

 解决方法;

方法一:在Program Argument里添加主机名和端口号,该方法适合动态获取host和port的情况。

 

 

 方法二:直接将读取文本流写死

 DataStreamSource<String> lineDataStream = env.socketTextStream("hadoop102", 7777);