Flink 连接被拒绝：localhost/127.0.0.1:8081

Question

我收到以下错误

org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannel$AnnotatedConnectException：连接被拒绝：localhost/127.0.0.1:8081

在尝试使用 Flink 流式传输数据时。大约一个月前我的代码运行良好，现在我收到此错误。在我还能够通过访问http://localhost:8081 上的 Flink Web Dashboard 来监控流式传输进度之前，现在我的浏览器返回一个错误，它无法访问服务器“localhost”。可能是什么问题呢？先感谢您。

错误信息的完整输出：

org.apache.flink.client.program.ProgramInvocationException：无法检索执行结果。 （作业编号：cfa44a8fd6a62f51ef8c0f956d55ee56） 在 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) 在示例.WaterLevelKafka.main(WaterLevelKafka.java:124) 在 sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) 在 sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) 在 sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) 在 java.lang.reflect.Method.invoke(Method.java:498) 在 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$11(CliFrontend.java:1120) 在 java.security.AccessController.doPrivileged（本机方法） 在 javax.security.auth.Subject.doAs(Subject.java:422) 在 org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1836) 在 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$8(RestClusterClient.java:379) 在 java.util.concurrent.CompletableFuture.uniExceptionally(CompletableFuture.java:870) 在 java.util.concurrent.CompletableFuture$UniExceptionally.tryFire(CompletableFuture.java:852) 在 java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474) 在 java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1977) 在 org.apache.flink.runtime.concurrent.FutureUtils.lambda$retryOperationWithDelay$5(FutureUtils.java:213) 在 java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:760) 在 java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:736) 在 java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474) 在 java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1977) 在 org.apache.flink.runtime.rest.RestClient.lambda$submitRequest$1(RestClient.java:276) 在 org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:511) 在 org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.notifyListeners0(DefaultPromise.java:504) 在 org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:483) 在 org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:424) 在 org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.tryFailure(DefaultPromise.java:121) 在 org.apache.flink.shaded.netty4.io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.fulfillConnectPromise(AbstractNioChannel.java:327) 在 org.apache.flink.shaded.netty4.io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:343) 在 org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:633) 在 org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:580) 在 org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:497) 在 org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:459) 在 org.apache.flink.shaded.netty4.io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:884) 在 org.apache.flink.shaded.netty4.io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) 在 java.lang.Thread.run(Thread.java:745) 原因：java.util.concurrent.CompletionException：org.apache.flink.runtime.concurrent.FutureUtils$RetryException：无法完成操作。重试次数已用尽。 在 java.util.concurrent.CompletableFuture.encodeRelay(CompletableFuture.java:326) 在 java.util.concurrent.CompletableFuture.completeRelay(CompletableFuture.java:338) 在 java.util.concurrent.CompletableFuture.uniRelay(CompletableFuture.java:911) 在 java.util.concurrent.CompletableFuture$UniRelay.tryFire(CompletableFuture.java:899) ... 22 更多 原因：org.apache.flink.runtime.concurrent.FutureUtils$RetryException：无法完成操作。重试次数已用尽。 ... 20 更多 引起：java.util.concurrent.CompletionException：org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannel$AnnotatedConnectException：连接被拒绝：localhost/127.0.0.1:8081 在 java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:292) 在 java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:308) 在 java.util.concurrent.CompletableFuture.uniCompose(CompletableFuture.java:943) 在 java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:926) ... 17 更多 引起：org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannel$AnnotatedConnectException：连接被拒绝：localhost/127.0.0.1:8081 在 sun.nio.ch.SocketChannelImpl.checkConnect(Native Method) 在 sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717) 在 org.apache.flink.shaded.netty4.io.netty.channel.socket.nio.NioSocketChannel.doFinishConnect(NioSocketChannel.java:325) 在 org.apache.flink.shaded.netty4.io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:340) ... 7 更多 引起：java.net.ConnectException：连接被拒绝 ... 11 更多

Answer 1

Apache flink 集群好像没有运行。

你只需要启动它：

./bin/start-cluster.sh  # Start Flink