Hi Felipe, glad this helped and you found the problematic dependencies!
Best, Nico On Fri, Nov 26, 2021 at 12:32 PM Felipe Gutierrez < felipe.o.gutier...@gmail.com> wrote: > hey Nico, you nailed it :tada: > > after doing "./mvnw dependency:tree | less" I saw scala 2.13 inside > spring-kafka-test. I excluded it and the error was gone. > > <dependency> > <groupId>org.springframework.kafka</groupId> > <artifactId>spring-kafka-test</artifactId> > <!--<version>2.8.0</version>--> > <!--<scope>test</scope>--> > <exclusions> > <exclusion> > <groupId>com.fasterxml.jackson.module</groupId> > <artifactId>jackson-module-scala_2.13</artifactId> > </exclusion> > <exclusion> > <groupId>org.scala-lang.modules</groupId> > <artifactId>scala-collection-compat_2.13</artifactId> > </exclusion> > <exclusion> > <groupId>org.scala-lang.modules</groupId> > <artifactId>scala-java8-compat_2.13</artifactId> > </exclusion> > <exclusion> > <groupId>com.typesafe.scala-logging</groupId> > <artifactId>scala-logging_2.13</artifactId> > </exclusion> > </exclusions> > </dependency> > > Thank you very much! > Felipe > > *--* > *-- Felipe Gutierrez* > *-- skype: felipe.o.gutierrez* > > > On Fri, Nov 26, 2021 at 12:08 PM Nicolaus Weidner < > nicolaus.weid...@ververica.com> wrote: > >> 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 < >> nicolaus.weid...@ververica.com> 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 < >>> 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* >>>> >>>
