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)
