Hi Felipe, can you check for Scala 2.13 dependencies on your classpath (parasitic was only introduced in Scala 2.13)? Not sure if that comes from Spring Boot 2.6 or something else. If you use Flink 1.13 or lower, it will just use whatever version is on the classpath, so you have to make sure that only Scala 2.11 or 2.12 (depending on your Flink version) is on the classpath, else clashes can occur.
... that said, even with Flink 1.14+, while the RPC system should not suffer this problem anymore, other components may. Best, Nico On Fri, Nov 26, 2021 at 11:21 AM Nicolaus Weidner < [email protected]> wrote: > Hi Felipe, > > just a quick question to make sure: did you do a full rebuild of your > project after changing the Spring boot version? > > Best, > Nico > > On Thu, Nov 25, 2021 at 8:01 PM Felipe Gutierrez < > [email protected]> wrote: > >> Hi community, >> >> I am using Flink 1.11 + Java 8 and I was updating my application from >> Spring boot 1 to spring boot 2.6. Then my Integration Test of Flink + Kafka >> started giving me this error: "java.lang.NoClassDefFoundError: >> scala/concurrent/ExecutionContext$parasitic$". The older version of spring >> boot 1 I didn't have this error. The exact line on my INT test is where I >> use: >> >> org.apache.flink.runtime.minicluster.TestingMiniCluster flink; >> flink.start(); >> >> I also have this line that I am thinking to replace. but I don't think it >> is related >> import scala.concurrent.duration.FiniteDuration; >> private FiniteDuration timeout = new FiniteDuration(15L, >> TimeUnit.SECONDS); >> >> I tried to add this dependency but it didn't make any difference. >> <dependency> >> <groupId>org.scala-lang</groupId> >> <artifactId>scala-library</artifactId> >> <version>2.12.0</version> >> </dependency> >> >> Does anybody have an idea of what I am missing? >> >> Full stack trace: >> java.lang.NoClassDefFoundError: >> scala/concurrent/ExecutionContext$parasitic$ >> >> at >> scala.concurrent.java8.FuturesConvertersImplCompat$.InternalCallbackExecutor(FuturesConvertersImplCompat.scala:7) >> at scala.compat.java8.FutureConverters$.toJava(FutureConverters.scala:72) >> at >> scala.compat.java8.FutureConverters$FutureOps$.toJava$extension(FutureConverters.scala:195) >> at akka.pattern.Patterns$.ask(Patterns.scala:94) >> at akka.pattern.Patterns.ask(Patterns.scala) >> at >> org.apache.flink.runtime.rpc.akka.SupervisorActor.startAkkaRpcActor(SupervisorActor.java:173) >> at >> org.apache.flink.runtime.rpc.akka.AkkaRpcService.registerAkkaRpcActor(AkkaRpcService.java:293) >> at >> org.apache.flink.runtime.rpc.akka.AkkaRpcService.startServer(AkkaRpcService.java:221) >> at org.apache.flink.runtime.rpc.RpcEndpoint.<init>(RpcEndpoint.java:129) >> at >> org.apache.flink.runtime.metrics.dump.MetricQueryService.<init>(MetricQueryService.java:75) >> at >> org.apache.flink.runtime.metrics.dump.MetricQueryService.createMetricQueryService(MetricQueryService.java:252) >> at >> org.apache.flink.runtime.metrics.MetricRegistryImpl.startQueryService(MetricRegistryImpl.java:182) >> at >> org.apache.flink.runtime.minicluster.MiniCluster.start(MiniCluster.java:307) >> >> Thanks, >> Felipe >> *--* >> *-- Felipe Gutierrez* >> *-- skype: felipe.o.gutierrez* >> >
