Flink Connection拒绝：localhost / 127.0.0.1:8081

我收到以下错误

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：无法检索执行结果。（JobID：cfa44a8fd6a62f51ef8c0f956d55ee56）org.apache.flink.fogram.rest.RestClusterClient.submitJob（RestClusterClient.java:260）at org.apache.flink.client.program.ClusterClient.run（ClusterClient.java:486）at at org.apache.flink.streaming.api.environment.StreamContextEnvironment.execute（StreamContextEnvironment.java:66）at examples.WaterLevelKafka.main（WaterLevelKafka.java:124）at sun.reflect.NativeMethodAccessorImpl.invoke0（Native Method）at sun。在org.apache.flink的java.lang.reflect.Method.invoke（Method.java:498）的sun.reflect.DelegatingMethodAccessorImpl.invoke（DelegatingMethodAccessorImpl.java:43）中的reflect.NativeMethodAccessorImpl.invoke（NativeMethodAccessorImpl.java:62） 。客户。UserGroupInformation.doAs（UserGroupInformation.java:1836）位于org.apache.flink.flink.client.cli.CliFrontend.main上的org.apache.flink.runtime.security.HadoopSecurityContext.runSecured（HadoopSecurityContext.java:41）（CliFrontend.java： 1120）引起：org.apache.flink.runtime.client.JobSubmissionException：无法提交JobGraph。在java.util.concurrent的java.util.concurrent.CompletableFuture.uniExceptionally（CompletableFuture.java:870）的org.apache.flink.client.program.rest.RestClusterClient.lambda $ submitJob $ 8（RestClusterClient.java:379）。在org.apache的java.util.concurrent.CompletableFuture.completeExceptionally（CompletableFuture.java:1977）的java.util.concurrent.CompletableFuture.postComplete（CompletableFuture.java:474）上的CompletableFuture $ UniExceptionally.tryFire（CompletableFuture.java:852） .flink。flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKeys（NioEventLoop.java:497）at org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.run（NioEventLoop.java） ：459）org.apache.flink.haded.netty4.io.netty.util.concurrent.SingleThreadEventExecutor $ 5.run（SingleThreadEventExecutor.java:884）at org.apache.flink.shaded.netty4.io.netty.util。 concurrent.FastThreadLocalRunnable.run（FastThreadLocalRunnable.java:30）at java.lang.Thread.run（Thread.java:745）引起：java.util.concurrent.CompletionException：org.apache.flink.runtime.concurrent.FutureUtils $ RetryException：无法完成操作。重试次数已用尽。在java.util.concurrent.CompletableFuture的java.util.concurrent.CompletableFuture.encodeRelay（CompletableFuture.java:326）中。java.util.conmple当前的java.util.concurrent.CompletableFuture.uniRelay（CompletableFuture.java:911）中的completeRelay（CompletableFuture.java:338）$ UniRelay.tryFire（CompletableFuture.java:899）... 22更多引起by：org.apache.flink.runtime.concurrent.FutureUtils $ RetryException：无法完成操作。重试次数已用尽。... 20更多引起：java.util.concurrent.CompletionException：org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannel $ AnnotatedConnectException：连接被拒绝：java.util中的localhost / 127.0.0.1:8081 .concurrent.CompletableFuture.encodeThrowable（CompletableFuture.java:292）at java.util.concurrent.CompletableFuture.completeThrowable（CompletableFuture.java:308）at java.util.concurrent.CompletableFuture.uniCompose（CompletableFuture。