Я получаю следующую ошибку
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannel $ AnnotatedConnectException: в соединении отказано: localhost / 127.0.0.1: 8081
при попытке потоковой передачи данных с помощью Flink.Мой код работал нормально около месяца назад, и теперь я получаю эту ошибку.Раньше мне также удавалось наблюдать за процессом потоковой передачи, обращаясь к Flink Web Dashboard на http://localhost:8081, и теперь мой браузер возвращает ошибку, из-за которой он не может получить доступ к серверу "localhost".В чем может быть проблема?Заранее спасибо.
Полный вывод сообщения об ошибке:
org.apache.flink.client.program.ProgramInvocationException: Не удалось получить результат выполнения.(JobID: cfa44a8fd6a62f51ef8c0f956d55ee56) по адресу org.apache.flink.client.program.rest.RestClusterClient.submitJob (RestClusterClient.java:260) в org.apache.flink.client.program.Clusent (клиент) клиентorg.apache.flink.streaming.api.environment.StreamContextEnvironment.execute (StreamContextEnvironment.java:66) в examples.WaterLevelKafka.main (WaterLevelKafka.java:124) в sun.reflect.NativeMethodAccessorImpl.invoke at0.отражать.client.program.PackagedProgram.callMainMethod (PackagedProgram.java:529) в org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution (PackagedProgram.java:421) в org.apache.flink.cliun.Program.client.program(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.cubentExob:Не удалось отправить JobGraph.в org.apache.flink.client.program.rest.RestClusterClient.lambda $ submitJob $ 8 (RestClusterClient.java:379) в java.util.concurrent.CompletableFuture.uniExceptionally (CompletableFuture.java:870) в java.util.c.CompletableFuture $ UniExceptionally.tryFire (CompletableFuture.java:852) в java.util.concurrent.CompletableFuture.postComplete (CompletableFuture.java:474) в java.util.concurrent.CompletableFuture.completeExceptionally (CompletableFache.j).flink.runtime.concurrent. FutureUtils.lambdaCompletableFuture.java:736) в java.util.concurrent.CompletableFuture.postComplete (CompletableFuture.java:474) в java.util.concurrent.CompletableFuture.completeExceptionally (CompletableFuture.java:1977) в org.apache.frest.un.RestClient.lambda $ submitRequest $ 1 (RestClient.java:276) at 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.javag: 327)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) в организации.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.uniFate) at 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 (java.jpg)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 (собственный метод) в 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