看起来是类似的，不过这个报错应该是作业失败之后的报错，看还有没有其他的异常日志。
Best, Feng On Sat, Nov 4, 2023 at 3:26 PM Ray <leibo1...@163.com> wrote: > 各位专家：当前遇到如下问题1、场景：在使用Yarn场景下提交flink任务2、版本：Flink1.15.03、日志：查看yarn上的日志发下，版本上的问题2023-11-04 > 15:04:42,313 ERROR org.apache.flink.util.FatalExitExceptionHandler > [] - FATAL: Thread 'flink-akka.actor.internal-dispatcher-3' produced an > uncaught exception. Stopping the process...java.lang.NoClassDefFoundError: > akka/actor/dungeon/FaultHandling$$anonfun$handleNonFatalOrInterruptedException$1 > at > akka.actor.dungeon.FaultHandling.handleNonFatalOrInterruptedException(FaultHandling.scala:334) > ~[flink-rpc-akka_abb25197-9eee-499b-8c1f-f52d0afc4374.jar:1.15.0] > at > akka.actor.dungeon.FaultHandling.handleNonFatalOrInterruptedException$(FaultHandling.scala:334) > ~[flink-rpc-akka_abb25197-9eee-499b-8c1f-f52d0afc4374.jar:1.15.0] > at > akka.actor.ActorCell.handleNonFatalOrInterruptedException(ActorCell.scala:411) > ~[flink-rpc-akka_abb25197-9eee-499b-8c1f-f52d0afc4374.jar:1.15.0] > at akka.actor.ActorCell.invoke(ActorCell.scala:551) > ~[flink-rpc-akka_abb25197-9eee-499b-8c1f-f52d0afc4374.jar:1.15.0] > at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270) > ~[flink-rpc-akka_abb25197-9eee-499b-8c1f-f52d0afc4374.jar:1.15.0] > at akka.dispatch.Mailbox.run(Mailbox.scala:231) > ~[flink-rpc-akka_abb25197-9eee-499b-8c1f-f52d0afc4374.jar:1.15.0] > at akka.dispatch.Mailbox.exec(Mailbox.scala:243) > [flink-rpc-akka_abb25197-9eee-499b-8c1f-f52d0afc4374.jar:1.15.0] > at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289) > [?:1.8.0_181] > at > java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056) > [?:1.8.0_181] > at > java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692) > [?:1.8.0_181] > at > java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:157) > [?:1.8.0_181] > Caused by: java.lang.ClassNotFoundException: > akka.actor.dungeon.FaultHandling$$anonfun$handleNonFatalOrInterruptedException$1 > at java.net.URLClassLoader.findClass(URLClassLoader.java:381) > ~[?:1.8.0_181] > at java.lang.ClassLoader.loadClass(ClassLoader.java:424) > ~[?:1.8.0_181] > at > org.apache.flink.core.classloading.ComponentClassLoader.loadClassFromComponentOnly(ComponentClassLoader.java:149) > ~[flink-dist-1.15.0.jar:1.15.0] > at > org.apache.flink.core.classloading.ComponentClassLoader.loadClass(ComponentClassLoader.java:112) > ~[flink-dist-1.15.0.jar:1.15.0] > at java.lang.ClassLoader.loadClass(ClassLoader.java:357) > ~[?:1.8.0_181] > ... 11 more > 2023-11-04 15:04:42,324 ERROR > org.apache.flink.runtime.util.ClusterUncaughtExceptionHandler [] - WARNING: > Thread 'flink-shutdown-hook-1' produced an uncaught exception. If you want > to fail on uncaught exceptions, then configure > cluster.uncaught-exception-handling accordingly > java.lang.NoClassDefFoundError: > scala/collection/convert/Wrappers$MutableSetWrapper > at > scala.collection.convert.AsScalaConverters.asScalaSet(AsScalaConverters.scala:126) > ~[flink-rpc-akka_abb25197-9eee-499b-8c1f-f52d0afc4374.jar:1.15.0] > at > scala.collection.convert.AsScalaConverters.asScalaSet$(AsScalaConverters.scala:124) > ~[flink-rpc-akka_abb25197-9eee-499b-8c1f-f52d0afc4374.jar:1.15.0] > at > akka.util.ccompat.package$JavaConverters$.asScalaSet(package.scala:86) > ~[flink-rpc-akka_abb25197-9eee-499b-8c1f-f52d0afc4374.jar:1.15.0] > at > scala.collection.convert.DecorateAsScala.$anonfun$asScalaSetConverter$1(DecorateAsScala.scala:59) > ~[flink-rpc-akka_abb25197-9eee-499b-8c1f-f52d0afc4374.jar:1.15.0] > at > scala.collection.convert.Decorators$AsScala.asScala(Decorators.scala:25) > ~[flink-rpc-akka_abb25197-9eee-499b-8c1f-f52d0afc4374.jar:1.15.0] > at > akka.actor.CoordinatedShutdown$tasks$.totalDuration(CoordinatedShutdown.scala:481) > ~[flink-rpc-akka_abb25197-9eee-499b-8c1f-f52d0afc4374.jar:1.15.0] > at > akka.actor.CoordinatedShutdown.totalTimeout(CoordinatedShutdown.scala:784) > ~[flink-rpc-akka_abb25197-9eee-499b-8c1f-f52d0afc4374.jar:1.15.0] > at > akka.actor.CoordinatedShutdown$.$anonfun$initJvmHook$1(CoordinatedShutdown.scala:271) > ~[flink-rpc-akka_abb25197-9eee-499b-8c1f-f52d0afc4374.jar:1.15.0] > at > akka.actor.CoordinatedShutdown$$anon$3.run(CoordinatedShutdown.scala:814) > ~[flink-rpc-akka_abb25197-9eee-499b-8c1f-f52d0afc4374.jar:1.15.0] > Caused by: java.lang.ClassNotFoundException: > scala.collection.convert.Wrappers$MutableSetWrapper > at java.net.URLClassLoader.findClass(URLClassLoader.java:381) > ~[?:1.8.0_181] > at java.lang.ClassLoader.loadClass(ClassLoader.java:424) > ~[?:1.8.0_181] > at > org.apache.flink.core.classloading.ComponentClassLoader.loadClassFromComponentOnly(ComponentClassLoader.java:149) > ~[flink-dist-1.15.0.jar:1.15.0] > at > org.apache.flink.core.classloading.ComponentClassLoader.loadClass(ComponentClassLoader.java:112) > ~[flink-dist-1.15.0.jar:1.15.0] > at java.lang.ClassLoader.loadClass(ClassLoader.java:357) > ~[?:1.8.0_181] > ... 9 more > > 4、查看Issue上，[FLINK-25998] Flink akka runs into NoClassDefFoundError on > shutdown - ASF JIRA (apache.org) > 不知道与这个是不是统一问题，目前步骤掉如何才能解决
