运行Flink作业报错：Job execution failed.

项目场景：

一个将本地文本文件写入到MySQL的Flink作业
<hr> 标题形貌

运行作业时报错：Exception in thread "main" org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
由于错误导致Flink作业不能完成

1. 报错信息：
2. Exception in thread "main" org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
3.     at org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144)
4.     at org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$3(MiniClusterJobClient.java:137)
5.     at java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:602)
6.     at java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:577)
7.     at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474)
8.     at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1962)
9.     at org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$0(AkkaInvocationHandler.java:237)
10.     at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:760)
11.     at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:736)
12.     at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474)
13.     at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1962)
14.     at org.apache.flink.runtime.concurrent.FutureUtils$1.onComplete(FutureUtils.java:1081)
15.     at akka.dispatch.OnComplete.internal(Future.scala:264)
16.     at akka.dispatch.OnComplete.internal(Future.scala:261)
17.     at akka.dispatch.japi$CallbackBridge.apply(Future.scala:191)
18.     at akka.dispatch.japi$CallbackBridge.apply(Future.scala:188)
19.     at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:32)
20.     at org.apache.flink.runtime.concurrent.Executors$DirectExecutionContext.execute(Executors.java:73)
21.     at scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:40)
22.     at scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:248)
23.     at akka.pattern.PromiseActorRef.$bang(AskSupport.scala:572)
24.     at akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:22)
25.     at akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:21)
26.     at scala.concurrent.Future$$anonfun$andThen$1.apply(Future.scala:436)
27.     at scala.concurrent.Future$$anonfun$andThen$1.apply(Future.scala:435)
28.     at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:32)
29.     at akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:55)
30.     at akka.dispatch.BatchingExecutor$BlockableBatch$$anonfun$run$1.apply$mcV$sp(BatchingExecutor.scala:91)
31.     at akka.dispatch.BatchingExecutor$BlockableBatch$$anonfun$run$1.apply(BatchingExecutor.scala:91)
32.     at akka.dispatch.BatchingExecutor$BlockableBatch$$anonfun$run$1.apply(BatchingExecutor.scala:91)
33.     at scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:72)
34.     at akka.dispatch.BatchingExecutor$BlockableBatch.run(BatchingExecutor.scala:90)
35.     at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:40)
36.     at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:44)
37.     at akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
38.     at akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
39.     at akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
40.     

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！qidao123.com:ToB企服之家，中国第一个企服评测及软件市场,开放入驻,技术点评得现金