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*
>>>
>>
