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