忽略吧。升级的时候多个版本混合在一起导致的应该是，我全部升级完后没这个问题了。
yidan zhao <hinobl...@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
