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*
