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] [Updated] (FLINK-22718) Could not create actor system
Date Thu, 20 May 2021 02:56:00 GMT

     [ https://issues.apache.org/jira/browse/FLINK-22718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

HYUNHOO KWON updated FLINK-22718:
---------------------------------
    Summary: Could not create actor system  (was: java.lang.Exception: Could not create actor
system)

> 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
>            Priority: Major
>
> * 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