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

Question

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个
附件

Answer 1

问题已经解决，因为只在一台服务器上安装了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模式也需要这样。