查看Job Manager里面的日志
发现错误,java.lang.RuntimeException: No data for required key 'port'
解决方法;
方法一:在Program Argument里添加主机名和端口号,该方法适合动态获取host和port的情况。
方法二:直接将读取文本流写死
DataStreamSource<String> lineDataStream = env.socketTextStream("hadoop102", 7777);
- Internal required server Flink errorinternal required server flink internal server error post internal server error get internal jupyter server error connection internal fatal error critical-startup-errors internal critical startup error 39 internal texist unexpected internal stream error error 0x80070003 x internal cmake not internal required