[jira] [Created] (FLINK-22718) java.lang.Exception: Could not create actor system

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-22718) java.lang.Exception: Could not create actor system

Shang Yuanchun (Jira)
HYUNHOO KWON created FLINK-22718:
------------------------------------

             Summary: java.lang.Exception: Could not create actor system
                 Key: FLINK-22718
                 URL: https://issues.apache.org/jira/browse/FLINK-22718
             Project: Flink
          Issue Type: Bug
    Affects Versions: 1.12.3
            Reporter: HYUNHOO KWON


* Java Flink local test failure (Could not create actor system). Only on 1.12.3v.
 ** No issue on 1.11.1v, 1.12.2v and 1.13.0v
 * Error Message
 **
{code:java}
java.lang.Exception: Could not create actor systemjava.lang.Exception: Could not create actor system at org.apache.flink.runtime.clusterframework.BootstrapTools.startLocalActorSystem(BootstrapTools.java:281) at org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils$AkkaRpcServiceBuilder.createAndStart(AkkaRpcServiceUtils.java:361) at org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils$AkkaRpcServiceBuilder.createAndStart(AkkaRpcServiceUtils.java:344) at org.apache.flink.runtime.minicluster.MiniCluster.createLocalRpcService(MiniCluster.java:952) at org.apache.flink.runtime.minicluster.MiniCluster.start(MiniCluster.java:288) at org.apache.flink.client.program.PerJobMiniClusterFactory.submitJob(PerJobMiniClusterFactory.java:75) at org.apache.flink.client.deployment.executors.LocalExecutor.execute(LocalExecutor.java:85) at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.executeAsync(StreamExecutionEnvironment.java:1905) at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:1796) at org.apache.flink.streaming.api.environment.LocalStreamEnvironment.execute(LocalStreamEnvironment.java:69) at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:1782) at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:1765) at com.kakao.bi.ka.conversion.job.KaConversion.streamKaConversion(KaConversion.java:56) at com.kakao.bi.ka.conversion.KaConversionApplication.main(KaConversionApplication.java:9)Caused by: java.lang.NoClassDefFoundError: akka/actor/ExtensionId$class at org.apache.flink.runtime.akka.RemoteAddressExtension$.<init>(RemoteAddressExtension.scala:32) at org.apache.flink.runtime.akka.RemoteAddressExtension$.<clinit>(RemoteAddressExtension.scala) at org.apache.flink.runtime.akka.AkkaUtils$.getAddress(AkkaUtils.scala:804) at org.apache.flink.runtime.akka.AkkaUtils.getAddress(AkkaUtils.scala) at org.apache.flink.runtime.clusterframework.BootstrapTools.startActorSystem(BootstrapTools.java:298) at org.apache.flink.runtime.clusterframework.BootstrapTools.startLocalActorSystem(BootstrapTools.java:279) ... 13 moreCaused by: java.lang.ClassNotFoundException: akka.actor.ExtensionId$class at java.net.URLClassLoader.findClass(URLClassLoader.java:382) at java.lang.ClassLoader.loadClass(ClassLoader.java:424) at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:349) at java.lang.ClassLoader.loadClass(ClassLoader.java:357) ... 19 more
{code}

 * dependency
 **
{code:java}
ext {
    flinkScalaVersion = '2.12'
    flinkVersion = '1.12.3'
}{code}

 **
{code:java}
dependencies {
    compileOnly 'org.projectlombok:lombok:1.18.8'
    annotationProcessor 'org.projectlombok:lombok:1.18.8'
    compile group: 'com.typesafe', name: 'config', version: '1.3.4'
    compile group: 'org.apache.httpcomponents', name: 'httpclient', version: '4.5.10'
    compile group: 'org.apache.flink', name: 'flink-java', version: "$flinkVersion"
    compile group: 'org.apache.flink', name: "flink-streaming-java_$flinkScalaVersion", version: "$flinkVersion"
    compile group: 'org.apache.flink', name: "flink-clients_$flinkScalaVersion", version: "$flinkVersion"
    compile group: 'org.apache.flink', name: "flink-connector-kafka_$flinkScalaVersion", version: "$flinkVersion"
    compile group: 'org.apache.flink', name: "flink-connector-elasticsearch7_$flinkScalaVersion", version: "$flinkVersion"
    testCompile group: 'junit', name: 'junit', version: '4.12'
}
{code}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)