[
https://issues.apache.org/jira/browse/FLINK-33514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17799987#comment-17799987
]
Binh-Nguyen Tran edited comment on FLINK-33514 at 12/23/23 3:12 AM:
--------------------------------------------------------------------
This could be due to outdated Kryo lib not supported by java 17+. I encountered
this issue and got it working again by downgrading java to 11.
There is an open PR to upgrade the Kryo lib to support newer JDK here:
[https://github.com/apache/flink/pull/22660]
was (Author: tbnguyen1407):
This could be due to outdated Kryo lib not supported by java 17+. I encountered
this issue and got it working again by downgrading java to 11.
There is an open PR to upgrade the Kryo lib to support newer JDK here:
[https://github.com/apache/flink/pull/22660]
> FlinkScalaKryoInstantiator class not found in KryoSerializer
> ------------------------------------------------------------
>
> Key: FLINK-33514
> URL: https://issues.apache.org/jira/browse/FLINK-33514
> Project: Flink
> Issue Type: Bug
> Components: API / Core
> Affects Versions: 1.18.0
> Reporter: Jake.zhang
> Priority: Minor
>
> {code:java}
> 16:03:13,402 INFO
> org.apache.flink.api.java.typeutils.runtime.kryo.KryoSerializer [] - Kryo
> serializer scala extensions are not available.
> java.lang.ClassNotFoundException:
> org.apache.flink.runtime.types.FlinkScalaKryoInstantiator
> at java.net.URLClassLoader.findClass(URLClassLoader.java:387)
> ~[?:1.8.0_341]
> at java.lang.ClassLoader.loadClass(ClassLoader.java:418) ~[?:1.8.0_341]
> at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:355)
> ~[?:1.8.0_341]
> at java.lang.ClassLoader.loadClass(ClassLoader.java:351) ~[?:1.8.0_341]
> at java.lang.Class.forName0(Native Method) ~[?:1.8.0_341]
> at java.lang.Class.forName(Class.java:264) ~[?:1.8.0_341]
> at
> org.apache.flink.api.java.typeutils.runtime.kryo.KryoSerializer.getKryoInstance(KryoSerializer.java:487)
> ~[flink-core-1.18.0.jar:1.18.0]
> at
> org.apache.flink.api.java.typeutils.runtime.kryo.KryoSerializer.checkKryoInitialized(KryoSerializer.java:522)
> ~[flink-core-1.18.0.jar:1.18.0]
> at
> org.apache.flink.api.java.typeutils.runtime.kryo.KryoSerializer.deserialize(KryoSerializer.java:394)
> ~[flink-core-1.18.0.jar:1.18.0]
> at
> org.apache.flink.api.java.typeutils.runtime.PojoSerializer.deserialize(PojoSerializer.java:412)
> ~[flink-core-1.18.0.jar:1.18.0]
> at
> org.apache.flink.streaming.runtime.streamrecord.StreamElementSerializer.deserialize(StreamElementSerializer.java:190)
> ~[flink-streaming-java-1.18.0.jar:1.18.0]
> at
> org.apache.flink.streaming.runtime.streamrecord.StreamElementSerializer.deserialize(StreamElementSerializer.java:43)
> ~[flink-streaming-java-1.18.0.jar:1.18.0]
> at
> org.apache.flink.runtime.plugable.NonReusingDeserializationDelegate.read(NonReusingDeserializationDelegate.java:53)
> ~[flink-runtime-1.18.0.jar:1.18.0]
> at
> org.apache.flink.runtime.io.network.api.serialization.NonSpanningWrapper.readInto(NonSpanningWrapper.java:337)
> ~[flink-runtime-1.18.0.jar:1.18.0]
> at
> org.apache.flink.runtime.io.network.api.serialization.SpillingAdaptiveSpanningRecordDeserializer.readNonSpanningRecord(SpillingAdaptiveSpanningRecordDeserializer.java:128)
> ~[flink-runtime-1.18.0.jar:1.18.0]
> at
> org.apache.flink.runtime.io.network.api.serialization.SpillingAdaptiveSpanningRecordDeserializer.readNextRecord(SpillingAdaptiveSpanningRecordDeserializer.java:103)
> ~[flink-runtime-1.18.0.jar:1.18.0]
> at
> org.apache.flink.runtime.io.network.api.serialization.SpillingAdaptiveSpanningRecordDeserializer.getNextRecord(SpillingAdaptiveSpanningRecordDeserializer.java:93)
> ~[flink-runtime-1.18.0.jar:1.18.0]
> at
> org.apache.flink.streaming.runtime.io.AbstractStreamTaskNetworkInput.emitNext(AbstractStreamTaskNetworkInput.java:100)
> ~[flink-streaming-java-1.18.0.jar:1.18.0]
> at
> org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:65)
> ~[flink-streaming-java-1.18.0.jar:1.18.0]
> at
> org.apache.flink.streaming.runtime.io.StreamMultipleInputProcessor.processInput(StreamMultipleInputProcessor.java:85)
> ~[flink-streaming-java-1.18.0.jar:1.18.0]
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:562)
> ~[flink-streaming-java-1.18.0.jar:1.18.0]
> at
> org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:231)
> ~[flink-streaming-java-1.18.0.jar:1.18.0]
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:858)
> ~[flink-streaming-java-1.18.0.jar:1.18.0]
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:807)
> ~[flink-streaming-java-1.18.0.jar:1.18.0]
> at
> org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:953)
> [flink-runtime-1.18.0.jar:1.18.0]
> at
> org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:932)
> [flink-runtime-1.18.0.jar:1.18.0]
> at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:746)
> [flink-runtime-1.18.0.jar:1.18.0]
> at org.apache.flink.runtime.taskmanager.Task.run(Task.java:562)
> [flink-runtime-1.18.0.jar:1.18.0]
> at java.lang.Thread.run(Thread.java:750) [?:1.8.0_341] {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
