org.apache.spark.SparkException: Failed to register classes with Kryo

  1. 0

    hadoop writables NotSerializableException with Apache Spark API

    Stack Overflow | 2 years ago | Vijay Innamuri
    org.apache.spark.SparkException: Failed to register classes with Kryo
  2. 0

    java.lang.ClassCastException: org.apache.hadoop.io.LongWritable cannot be cast to java.lang.String - Grokbase

    grokbase.com | 8 months ago
    java.lang.ClassCastException: org.apache.hadoop.io.LongWritable cannot be cast to java.lang.String
  3. 0

    Class Cast exception for the Hadoop new API

    Stack Overflow | 4 years ago | Raveesh Sharma
    java.lang.ClassCastException: org.apache.hadoop.io.LongWritable cannot be cast to org.apache.hadoop.io.Text
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

  5. 0

    Caused by: java.lang.ClassCastException: org.apache.hadoop.io.LongWritable cannot be cast to org.apache.hadoop.io.Text

    Stack Overflow | 2 years ago | Gajapathy
    java.lang.Exception: java.lang.ClassCastException: org.apache.hadoop.io.LongWritable cannot be cast to org.apache.hadoop.io.Text
  6. 0

    Type mismatch in key from map

    Stack Overflow | 1 year ago | rich
    java.lang.Exception: java.lang.ClassCastException: org.apache.hadoop.io.LongWritable cannot be cast to org.apache.hadoop.io.Text

    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.ClassCastException

      org.apache.hadoop.io.LongWritable cannot be cast to org.apache.spark.serializer.KryoRegistrator

      at org.apache.spark.serializer.KryoSerializer$$anonfun$newKryo$3.apply()
    2. Spark
      KryoSerializer$$anonfun$newKryo$3.apply
      1. org.apache.spark.serializer.KryoSerializer$$anonfun$newKryo$3.apply(KryoSerializer.scala:97)
      2. org.apache.spark.serializer.KryoSerializer$$anonfun$newKryo$3.apply(KryoSerializer.scala:97)
      2 frames
    3. Scala
      Option.map
      1. scala.Option.map(Option.scala:145)
      1 frame
    4. Spark
      JavaSparkContext.newAPIHadoopFile
      1. org.apache.spark.serializer.KryoSerializer.newKryo(KryoSerializer.scala:97)
      2. org.apache.spark.serializer.KryoSerializerInstance.<init>(KryoSerializer.scala:153)
      3. org.apache.spark.serializer.KryoSerializer.newInstance(KryoSerializer.scala:115)
      4. org.apache.spark.broadcast.TorrentBroadcast$.blockifyObject(TorrentBroadcast.scala:200)
      5. org.apache.spark.broadcast.TorrentBroadcast.writeBlocks(TorrentBroadcast.scala:101)
      6. org.apache.spark.broadcast.TorrentBroadcast.<init>(TorrentBroadcast.scala:84)
      7. org.apache.spark.broadcast.TorrentBroadcastFactory.newBroadcast(TorrentBroadcastFactory.scala:34)
      8. org.apache.spark.broadcast.TorrentBroadcastFactory.newBroadcast(TorrentBroadcastFactory.scala:29)
      9. org.apache.spark.broadcast.BroadcastManager.newBroadcast(BroadcastManager.scala:62)
      10. org.apache.spark.SparkContext.broadcast(SparkContext.scala:1051)
      11. org.apache.spark.rdd.NewHadoopRDD.<init>(NewHadoopRDD.scala:77)
      12. org.apache.spark.SparkContext.newAPIHadoopFile(SparkContext.scala:848)
      13. org.apache.spark.api.java.JavaSparkContext.newAPIHadoopFile(JavaSparkContext.scala:488)
      13 frames
    5. com.nsn.PMParser
      Parser2.main
      1. com.nsn.PMParser.Parser2.main(Parser2.java:56)
      1 frame