Hi Team,

While running java flink project in local, I am facing following issues: *Could
not create actor system ; Caused by: java.lang.NoSuchMethodError:
scala.Product.$init$(Lscala/Product;)V*
Could you suggest does flink java project needs scala at run time? What
versions might be incompatible.































*Exception in thread "main" java.lang.Exception: Could not create actor
system at
org.apache.flink.runtime.clusterframework.BootstrapTools.startLocalActorSystem(BootstrapTools.java:263)
at
org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils$AkkaRpcServiceBuilder.createAndStart(AkkaRpcServiceUtils.java:341)
at
org.apache.flink.runtime.minicluster.MiniCluster.createLocalRpcService(MiniCluster.java:793)
at
org.apache.flink.runtime.minicluster.MiniCluster.start(MiniCluster.java:271)
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:1812)
at
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:1713)
at
org.apache.flink.streaming.api.environment.LocalStreamEnvironment.execute(LocalStreamEnvironment.java:74)
at
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:1699)
at
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:1681)
at com.xx.DisFlinkService.execute(DisFlinkService.java:92) at
com.xxx.DisFlinkEmrApplication.main(DisFlinkEmrApplication.java:17) at
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498) at
com.intellij.rt.execution.application.AppMainV2.main(AppMainV2.java:114)Caused
by: java.lang.NoSuchMethodError: scala.Product.$init$(Lscala/Product;)V at
akka.util.Timeout.<init>(Timeout.scala:13) at
akka.actor.ActorSystem$Settings.<init>(ActorSystem.scala:329) at
akka.actor.ActorSystemImpl.<init>(ActorSystem.scala:686) at
akka.actor.RobustActorSystem.<init>(RobustActorSystem.scala:47) at
akka.actor.RobustActorSystem$.internalApply(RobustActorSystem.scala:96) at
akka.actor.RobustActorSystem$.apply(RobustActorSystem.scala:70) at
akka.actor.RobustActorSystem$.create(RobustActorSystem.scala:55) at
org.apache.flink.runtime.akka.AkkaUtils$.createActorSystem(AkkaUtils.scala:125)
at
org.apache.flink.runtime.akka.AkkaUtils.createActorSystem(AkkaUtils.scala)
at
org.apache.flink.runtime.clusterframework.BootstrapTools.startActorSystem(BootstrapTools.java:276)
at
org.apache.flink.runtime.clusterframework.BootstrapTools.startLocalActorSystem(BootstrapTools.java:260)*

Regards,
Vijay

Reply via email to