Can you show us the dependency tree of your project?
(If you are using maven, run "mvn dependency:tree")
On 5/7/2021 2:15 PM, Ragini Manjaiah wrote:
The scala version is same across the pom file . 2.11
On Fri, May 7, 2021 at 5:06 PM Chesnay Schepler <ches...@apache.org
<mailto:ches...@apache.org>> wrote:
It looks like you have different scala versions on the classpath.
Please
check that all your dependencies use the same scala version.
On 5/7/2021 1:25 PM, Ragini Manjaiah wrote:
> Hi ,
> I am surfacing when submitting flink from intellij IDE . what
> cloud the issues. Do need to change the scala version
>
> flink 1.11.3
> scala 2.11
>
> Exception in thread "main" java.lang.NoSuchMethodError:
> scala.Function1.$init$(Lscala/Function1;)V
> at
>
scala.concurrent.java8.FuturesConvertersImpl$CF.<init>(FutureConvertersImpl.scala:18)
> at
scala.compat.java8.FutureConverters$.toJava(FutureConverters.scala:61)
> at
>
scala.compat.java8.FutureConverters$FutureOps$.toJava$extension(FutureConverters.scala:185)
> at akka.pattern.Patterns$.ask(Patterns.scala:95)
> 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)
> at
>
org.apache.flink.client.program.PerJobMiniClusterFactory.submitJob(PerJobMiniClusterFactory.java:87)
> at
>
org.apache.flink.client.deployment.executors.LocalExecutor.execute(LocalExecutor.java:81)
> at
>
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.executeAsync(StreamExecutionEnvironment.java:1818)
> at
>
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:1714)
> at
>
org.apache.flink.streaming.api.environment.LocalStreamEnvironment.execute(LocalStreamEnvironment.java:74)
> at
>
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:1700)
> at org.sapphire.fullpayload.Application.main(Application.java:173)
