java.lang.RuntimeException: Could not deserialize NFA. at org.apache.flink.api.java.typeutils.runtime.JavaSerializer.deserialize(JavaSerializer.java:86)

Stack Overflow | static-max | 2 months ago
  1. 0

    Flink job throws ClassNotFoundException on job restart

    Stack Overflow | 2 months ago | static-max
    java.lang.RuntimeException: Could not deserialize NFA. at org.apache.flink.api.java.typeutils.runtime.JavaSerializer.deserialize(JavaSerializer.java:86)
  2. 0

    Issue While Deserializing Authentication object in OAuth2

    Stack Overflow | 9 months ago | Dhairyashil
    java.lang.ClassNotFoundException: org.hibernate.collection.PersistentBag
  3. 0

    How to deserialize Pipeline model in spark.ml?

    Stack Overflow | 2 years ago | Tim Malt
    java.lang.ClassNotFoundException: com.myCompany.spark.classifier.LabelTransformer
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

  5. 0

    ClassNotFoundException during readObject()

    GitHub | 4 years ago | harrah
    java.lang.ClassNotFoundException: ObjType$
  6. 0

    ClassNotFoundException during readObject()

    GitHub | 5 years ago | ihji
    java.lang.ClassNotFoundException: ObjType$

    10 unregistered visitors
    Not finding the right solution?
    Take a tour to get the most out of Samebug.

    Tired of useless tips?

    Automated exception search integrated into your IDE

    Root Cause Analysis

    1. java.lang.ClassNotFoundException

      org.apache.flink.streaming.connectors.kafka.internals.KafkaTopicPartition

      at java.net.URLClassLoader.findClass()
    2. Java RT
      ObjectInputStream.readObject
      1. java.net.URLClassLoader.findClass(URLClassLoader.java:381)
      2. java.lang.ClassLoader.loadClass(ClassLoader.java:424)
      3. sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:331)
      4. java.lang.ClassLoader.loadClass(ClassLoader.java:357)
      5. java.lang.Class.forName0(Native Method)
      6. java.lang.Class.forName(Class.java:348)
      7. java.io.ObjectInputStream.resolveClass(ObjectInputStream.java:626)
      8. java.io.ObjectInputStream.readNonProxyDesc(ObjectInputStream.java:1613)
      9. java.io.ObjectInputStream.readClassDesc(ObjectInputStream.java:1518)
      10. java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1774)
      11. java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351)
      12. java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2000)
      13. java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1924)
      14. java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801)
      15. java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351)
      16. java.io.ObjectInputStream.readObject(ObjectInputStream.java:371)
      16 frames
    3. flink-java
      JavaSerializer.deserialize
      1. org.apache.flink.api.java.typeutils.runtime.JavaSerializer.deserialize(JavaSerializer.java:83)
      2. org.apache.flink.api.java.typeutils.runtime.JavaSerializer.deserialize(JavaSerializer.java:31)
      2 frames
    4. org.apache.flink
      StreamTask.invoke
      1. org.apache.flink.runtime.state.DefaultOperatorStateBackend.getPartitionableState(DefaultOperatorStateBackend.java:107)
      2. org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase.initializeState(FlinkKafkaConsumerBase.java:323)
      3. org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:105)
      4. org.apache.flink.streaming.runtime.tasks.StreamTask.openAllOperators(StreamTask.java:396)
      5. org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:269)
      5 frames
    5. flink-runtime
      Task.run
      1. org.apache.flink.runtime.taskmanager.Task.run(Task.java:608)
      1 frame
    6. Java RT
      Thread.run
      1. java.lang.Thread.run(Thread.java:745)
      1 frame