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 < felipe.o.gutier...@gmail.com> 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* >
