You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Gary Yao (JIRA)" <ji...@apache.org> on 2019/01/24 16:07:00 UTC
[jira] [Updated] (FLINK-11431) Akka dependency not compatible with
java 9 or above
[ https://issues.apache.org/jira/browse/FLINK-11431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Gary Yao updated FLINK-11431:
-----------------------------
Issue Type: Sub-task (was: Bug)
Parent: FLINK-8033
> Akka dependency not compatible with java 9 or above
> ---------------------------------------------------
>
> Key: FLINK-11431
> URL: https://issues.apache.org/jira/browse/FLINK-11431
> Project: Flink
> Issue Type: Sub-task
> Components: Core
> Affects Versions: 1.7.1
> Reporter: Matthieu Bonneviot
> Priority: Minor
>
> 2019-01-24 14:43:52,059 ERROR akka.remote.Remoting - class [B cannot be cast to class [C ([B and [C are in module java.base of loader 'bootstrap')
> java.lang.ClassCastException: class [B cannot be cast to class [C ([B and [C are in module java.base of loader 'bootstrap')
> at akka.remote.artery.FastHash$.ofString(LruBoundedCache.scala:18)
> at akka.remote.serialization.ActorRefResolveCache.hash(ActorRefResolveCache.scala:61)
> at akka.remote.serialization.ActorRefResolveCache.hash(ActorRefResolveCache.scala:55)
> at akka.remote.artery.LruBoundedCache.getOrCompute(LruBoundedCache.scala:110)
> at akka.remote.RemoteActorRefProvider.resolveActorRef(RemoteActorRefProvider.scala:403)
> at akka.actor.SerializedActorRef.readResolve(ActorRef.scala:433)
> at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> at java.base/java.lang.reflect.Method.invoke(Method.java:566)
> at java.base/java.io.ObjectStreamClass.invokeReadResolve(ObjectStreamClass.java:1250)
> at java.base/java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2096)
> at java.base/java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1594)Running a jobmanager with java 11 fail with the following call stack:
> Flink master is using akka 2.4.20.
> After some investigation, the error in akka comes from the following line:
> def ofString(s: String): Int = {
> val chars = Unsafe.instance.getObject(s, EnvelopeBuffer.StringValueFieldOffset).asInstanceOf[Array[Char]]
> from java 9 it is now an array of byte. The akka code in the newer version is:
> public static int fastHash(String str) {
> ...
> if (isJavaVersion9Plus) {
> final byte[] chars = (byte[]) instance.getObject(str, stringValueFieldOffset);
> ...
> } else {
> final char[] chars = (char[]) instance.getObject(str, stringValueFieldOffset);
>
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)