Exception in thread “main“ org.apache.flink.runtime.client.JobExecutionException: Job execution fail

在这里插入图片描述


问题描述:

在使用Flink进行流式处理时,我连接的数据流是Socket,运行一段时间出现如下问题 Exception in thread "main" org.apache.flink.runtime.client.JobExecutionException: Job execution failed. at org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144) at org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$3(MiniClusterJobClient.java:137)

在这里插入图片描述

Exception in thread "main"<

猜你喜欢

转载自blog.csdn.net/m0_47256162/article/details/133063740