flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "HYUNHOO KWON (Jira)" <j...@apache.org>
Subject [jira] [Created] (FLINK-22718) java.lang.Exception: Could not create actor system
Date Thu, 20 May 2021 02:55:00 GMT
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)

Mime
View raw message