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

Reply via email to