You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by yidan zhao <hi...@gmail.com> on 2021/06/09 12:05:46 UTC
flink1.13.1启动时候taskmanager异常日志
目前来看不影响运行可能，但是是ERROR的日志。如下：
2021-06-09 20:04:41,194 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor [] -
Pausing and re-attempting registration in 10000 ms
2021-06-09 20:04:51,214 ERROR
org.apache.flink.runtime.taskexecutor.TaskExecutor [] -
Registration at ResourceManager failed due to an error
java.util.concurrent.CompletionException:
java.lang.ClassCastException: org.apache.flink.util.SerializedValue
cannot be cast to
org.apache.flink.runtime.registration.RegistrationResponse
at java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:273)
~[?:1.8.0_251]
at java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:280)
~[?:1.8.0_251]
at java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:673)
~[?:1.8.0_251]
at java.util.concurrent.CompletableFuture$UniAccept.tryFire(CompletableFuture.java:646)
~[?:1.8.0_251]
at java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:456)
[?:1.8.0_251]
at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:40)
[flink-dist_2.11-1.13.1.jar:1.13.1]
at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:44)
[flink-dist_2.11-1.13.1.jar:1.13.1]
at akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
[flink-dist_2.11-1.13.1.jar:1.13.1]
at akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
[flink-dist_2.11-1.13.1.jar:1.13.1]
at akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
[flink-dist_2.11-1.13.1.jar:1.13.1]
at akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
[flink-dist_2.11-1.13.1.jar:1.13.1]
Caused by: java.lang.ClassCastException:
org.apache.flink.util.SerializedValue cannot be cast to
org.apache.flink.runtime.registration.RegistrationResponse
at java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:670)
~[?:1.8.0_251]
... 8 more
Re: flink1.13.1启动时候taskmanager异常日志
Posted by yidan zhao <hi...@gmail.com>.
忽略吧。升级的时候多个版本混合在一起导致的应该是，我全部升级完后没这个问题了。
yidan zhao <hi...@gmail.com> 于2021年6月9日周三 下午8:05写道：
>
> 目前来看不影响运行可能，但是是ERROR的日志。如下：
> 2021-06-09 20:04:41,194 INFO
> org.apache.flink.runtime.taskexecutor.TaskExecutor [] -
> Pausing and re-attempting registration in 10000 ms
> 2021-06-09 20:04:51,214 ERROR
> org.apache.flink.runtime.taskexecutor.TaskExecutor [] -
> Registration at ResourceManager failed due to an error
> java.util.concurrent.CompletionException:
> java.lang.ClassCastException: org.apache.flink.util.SerializedValue
> cannot be cast to
> org.apache.flink.runtime.registration.RegistrationResponse
> at java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:273)
> ~[?:1.8.0_251]
> at java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:280)
> ~[?:1.8.0_251]
> at java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:673)
> ~[?:1.8.0_251]
> at java.util.concurrent.CompletableFuture$UniAccept.tryFire(CompletableFuture.java:646)
> ~[?:1.8.0_251]
> at java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:456)
> [?:1.8.0_251]
> at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:40)
> [flink-dist_2.11-1.13.1.jar:1.13.1]
> at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:44)
> [flink-dist_2.11-1.13.1.jar:1.13.1]
> at akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
> [flink-dist_2.11-1.13.1.jar:1.13.1]
> at akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
> [flink-dist_2.11-1.13.1.jar:1.13.1]
> at akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
> [flink-dist_2.11-1.13.1.jar:1.13.1]
> at akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
> [flink-dist_2.11-1.13.1.jar:1.13.1]
> Caused by: java.lang.ClassCastException:
> org.apache.flink.util.SerializedValue cannot be cast to
> org.apache.flink.runtime.registration.RegistrationResponse
> at java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:670)
> ~[?:1.8.0_251]
> ... 8 more