Flink only runs on java 8. There were efforts to add support for java 9 in 1.8 but in turned into a massive rabbit hole with rather wide implications, like the akka version upgrade that you just found.

On 24.01.2019 17:04, Matthieu Bonneviot wrote:
Hi
i am working on migrating my flink cluster to 1.7.1 with java 11.
I am facing a runtime error in the taskmanager:
2019-01-24 14:43:37,014 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)

This error is due to a code optimization done in akka which is not working
anymore from java 9.

I have open an issue for more details:
https://issues.apache.org/jira/browse/FLINK-11431

Are you facing the same issue?

Regards
Matthieu Bonneviot


Reply via email to