weixin_44829371
白灰黑
采纳率0%
2019-07-24 17:17 阅读 1.8k

flink-1.8.1测试运行自带的example/batch/WordCount出现以下问题

org.apache.flink.client.program.ProgramInvocationException:无法检索执行结果。(JobID:5a7165e1260c6316fa11d2760bd3d49f)
在org.apache.flink.client.program。rest .RestClusterClient.submitJob(RestClusterClient.java:260)
在org.apache.flink.client.program.ClusterClient.run(ClusterClient.java:486)
在org.apache.flink.streaming.api.environment.StreamContextEnvironment.execute(StreamContextEnvironment.java:66)
在org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:1511)
at com.dataartisans.streamledger.examples.simpletrade.SimpleTradeExample.main(SimpleTradeExample.java:98)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
在java.lang.reflect.Method.invoke(Method.java:497)
在org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:529)
在org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:421)
在org.apache.flink.client.program.ClusterClient.run(ClusterClient.java:426)
在org.apache.flink.client.cli.CliFrontend.executeProgram(CliFrontend.java:804)
在org.apache.flink.client.cli.CliFrontend.runProgram(CliFrontend.java:280)
在org.apache.flink.client.cli.CliFrontend.run(CliFrontend.java:215)
在org.apache.flink.client.cli.CliFrontend.parseParameters(CliFrontend.java:1044)
在org.apache.flink.client.cli.CliFrontend.lambda $ main $ 16(CliFrontend.java:1120)
at java.security.AccessController.doPrivileged(Native Method)
在javax.security.auth.Subject.doAs(Subject.java:422)
在org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1556)
在org.apache.flink.runtime.security.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:41)
在org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:1120)
引起:org.apache.flink.runtime.client.JobSubmissionException:无法提交JobGraph。
在org.apache.flink.client.program。rest .RestClusterClient.lambda $ submitJob $ 25(RestClusterClient.java:379)
at java.util.concurrent.CompletableFuture.uniExceptionally(CompletableFuture.java:870)
at 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)
在org.apache.flink.runtime.concurrent.FutureUtils.lambda $ retryOperationWithDelay $ 32(FutureUtils.java:213)
at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:760)
at java.util.concurrent.CompletableFuture $ UniWhenComplete.tryFire(CompletableFuture.java:736)
at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474)
at java.util.concurrent.CompletableFuture.postFire(CompletableFuture.java:561)
at java.util.concurrent.CompletableFuture $ UniCompose.tryFire(CompletableFuture.java:929)
at java.util.concurrent.CompletableFuture $ Completion.run(CompletableFuture.java:442)
在java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at java.util.concurrent.ThreadPoolExecutor $ Worker.run(ThreadPoolExecutor.java:617)
在java.lang。线程 .run(线程 .java:745)
引起:java.util.concurrent.CompletionException:org.apache.flink.runtime.concurrent.FutureUtils $ RetryException:无法完成操作。异常不可重试。
at java.util.concurrent.CompletableFuture.encodeRelay(CompletableFuture.java:326)
at java.util.concurrent.CompletableFuture.completeRelay(CompletableFuture.java:338)
at java.util.concurrent.CompletableFuture.uniRelay(CompletableFuture.java:911)
at java.util.concurrent.CompletableFuture $ UniRelay.tryFire(CompletableFuture.java:899)
......还有12个
引起:org.apache.flink.runtime.concurrent.FutureUtils $ RetryException:无法完成操作。异常不可重试。
......还有10个
引起:java.util.concurrent.CompletionException:org.apache.flink.runtime。rest .util.RestClientException:[作业提交失败。]
at java.util.concurrent.CompletableFuture.encodeRelay(CompletableFuture.java:326)
at java.util.concurrent.CompletableFuture.completeRelay(CompletableFuture.java:338)
at java.util.concurrent.CompletableFuture.uniRelay(CompletableFuture.java:911)
at java.util.concurrent.CompletableFuture.uniCompose(CompletableFuture.java:953)
at java.util.concurrent.CompletableFuture $ UniCompose.tryFire(CompletableFuture.java:926)
......还有4个
引起:org.apache.flink.runtime。rest .util.RestClientException:[作业提交失败。]
在org.apache.flink.runtime。rest .RestClient.parseResponse(RestClient.java:310)
在org.apache.flink.runtime。rest .RestClient.lambda $ submitRequest $ 364(RestClient.java:294)
at java.util.concurrent.CompletableFuture.uniCompose(CompletableFuture.java:952)
......还有5个
附件

  • 点赞
  • 写回答
  • 关注问题
  • 收藏
  • 复制链接分享

1条回答 默认 最新

  • weixin_44829371 白灰黑 2019-07-29 10:29

    问题已经解决,因为只在一台服务器上安装了flink-1.8.1,,属于本地模式。不能直接使用flink run /example/batch/WordCount.jar 需要指定
    本地模式的IP和port,,bin/flink run -m 10.xxx.xxx.xxx:port /example/batch/WordCount.jar
    测试运行SocketWordCount.jar模式也需要这样。

    点赞 1 评论 复制链接分享

相关推荐