[ https://issues.apache.org/jira/browse/FLINK-33514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800747#comment-17800747 ]
Martijn Visser commented on FLINK-33514: ---------------------------------------- [~Cyberness] I think this ticket lacks information in general in what's in the POM/build and what setup has been used (Java 8, 11, 17) and if this was an upgrade, or a newly started job. I'm assuming someone upgraded from a Flink version prior to 1.14 and didn't check the 1.15 release notes https://nightlies.apache.org/flink/flink-docs-master/release-notes/flink-1.15/ > 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)