apache-flink - 如何在 pod 中运行 flink jar

Question

我在作业 pod 中运行在 flink cmd 下方：

./opt/flink/bin/flink run ./opt/flink/examples/batch/WordCount.jar

然后它向我显示错误，我不知道如何修复它，但是在本地 flink 中相同的 cmd 是可以的。仪表板

使用默认输入数据集执行 WordCount 示例。使用 --input 指定文件输入。将结果打印到标准输出。使用 --output 指定输出路径。程序完成，出现以下异常：org.apache.flink.client.program.ProgramInvocationException：主要方法导致错误：java.util.concurrent.ExecutionException：org.apache.flink.runtime.client.JobSubmissionException：提交失败作业图。在 org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:302) 在 org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:198) 在 org.apache.flink.client .ClientUtils.executeProgram(ClientUtils.java:149) 在 org.apache.flink.client.cli.CliFrontend.executeProgram(CliFrontend.java:699) 在 org.apache.flink.client.cli.CliFrontend.run(CliFrontend.java :232) 在组织。org.apache.flink.client.cli.CliFrontend.lambda$main$10(CliFrontend.java:992) 在 org.apache.flink.runtime 的 apache.flink.client.cli.CliFrontend.parseParameters(CliFrontend.java:916) .security.contexts.NoOpSecurityContext.runSecured(NoOpSecurityContext.java:30) at org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:992) 原因：java.lang.RuntimeException: java.util.concurrent .ExecutionException: org.apache.flink.runtime.client.JobSubmissionException: 提交 JobGraph 失败。在 org.apache.flink.util.ExceptionUtils.rethrow(ExceptionUtils.java:277) 在 org.apache.flink.api.java.ExecutionEnvironment.executeAsync(ExecutionEnvironment.java:981) 在 org.apache.flink.client.program .ContextEnvironment.executeAsync(ContextEnvironment.java:124) 在 org.apache.flink.client.program.ContextEnvironment.execute(ContextEnvironment.java:72) 在 org.apache。flink.api.java.ExecutionEnvironment.execute(ExecutionEnvironment.java:873) 在 org.apache.flink.api.java.DataSet.collect(DataSet.java:413) 在 org.apache.flink.api.java.DataSet。 print(DataSet.java:1652) 在 org.apache.flink.examples.java.wordcount.WordCount.main(WordCount.java:96) 在 sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) 在 sun.reflect.NativeMethodAccessorImpl。 invoke(NativeMethodAccessorImpl.java:62) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:498) at org.apache.flink.client.program .PackagedProgram.callMainMethod(PackagedProgram.java:288) ... 8 更多原因：java.util.concurrent.ExecutionException: org.apache.flink.runtime.client.JobSubmissionException: 提交 JobGraph 失败。在 java.util.concurrent.CompletableFuture。reportGet(CompletableFuture.java:357) at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1895) at org.apache.flink.api.java.ExecutionEnvironment.executeAsync(ExecutionEnvironment.java:976) ... 19更多原因：org.apache.flink.runtime.client.JobSubmissionException：提交JobGraph失败。在 org.apache.flink.client.program.rest.RestClusterClient.lambda$submitJob$7(RestClusterClient.java:366) 在 java.util.concurrent.CompletableFuture.uniExceptionally(CompletableFuture.java:870) 在 java.util.concurrent。 CompletableFuture$UniExceptionally.tryFire(CompletableFuture.java:852) at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474) at java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1977) at org.apache .flink.runtime.concurrent.FutureUtils。

标签： apache-flink