kafka.common.KafkaException:

GitHub | Dieterbe | 5 months ago
  1. 0

    GitHub comment 227#228078692

    GitHub | 5 months ago | rayjohnson
    kafka.common.KafkaException:
  2. 0

    [SPARK-6977] PARSING_ERROR(2) in Spark Streaming - ASF JIRA

    apache.org | 1 year ago
    java.io.IOException: PARSING_ERROR(2)
  3. Speed up your debug routine!

    Automated exception search integrated into your IDE

  4. 0

    [SPARK-4105] FAILED_TO_UNCOMPRESS(5) errors when fetching shuffle data with sort-based shuffle - ASF JIRA

    apache.org | 11 months ago
    com.esotericsoftware.kryo.KryoException: java.io.IOException: failed to uncompress the chunk: FAILED_TO_UNCOMPRESS(5)
  5. 0

    [SPARK-5928] Remote Shuffle Blocks cannot be more than 2 GB - ASF JIRA

    apache.org | 11 months ago
    java.io.IOException: failed to uncompress the chunk: PARSING_ERROR(2)

    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.io.IOException

      failed to read chunk

      at org.xerial.snappy.SnappyInputStream.hasNextChunk()
    2. snappy-java
      SnappyInputStream.read
      1. org.xerial.snappy.SnappyInputStream.hasNextChunk(SnappyInputStream.java:433)
      2. org.xerial.snappy.SnappyInputStream.read(SnappyInputStream.java:167)
      2 frames
    3. Java RT
      DataInputStream.readLong
      1. java.io.DataInputStream.readFully(DataInputStream.java:195)
      2. java.io.DataInputStream.readLong(DataInputStream.java:416)
      2 frames
    4. Apache Kafka
      IteratorTemplate.hasNext
      1. kafka.message.ByteBufferMessageSet$$anon$1.readMessageFromStream(ByteBufferMessageSet.scala:118)
      2. kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:153)
      3. kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:85)
      4. kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:64)
      5. kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:56)
      6. kafka.message.ByteBufferMessageSet$$anon$2.makeNextOuter(ByteBufferMessageSet.scala:357)
      7. kafka.message.ByteBufferMessageSet$$anon$2.makeNext(ByteBufferMessageSet.scala:369)
      8. kafka.message.ByteBufferMessageSet$$anon$2.makeNext(ByteBufferMessageSet.scala:324)
      9. kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:64)
      10. kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:56)
      10 frames
    5. Scala
      Iterator$class.foreach
      1. scala.collection.Iterator$class.foreach(Iterator.scala:893)
      1 frame
    6. Apache Kafka
      ReplicaManager$$anonfun$appendToLocalLog$2.apply
      1. kafka.utils.IteratorTemplate.foreach(IteratorTemplate.scala:30)
      2. kafka.message.ByteBufferMessageSet.validateMessagesAndAssignOffsets(ByteBufferMessageSet.scala:427)
      3. kafka.log.Log.liftedTree1$1(Log.scala:339)
      4. kafka.log.Log.append(Log.scala:338)
      5. kafka.cluster.Partition$$anonfun$11.apply(Partition.scala:443)
      6. kafka.cluster.Partition$$anonfun$11.apply(Partition.scala:429)
      7. kafka.utils.CoreUtils$.inLock(CoreUtils.scala:231)
      8. kafka.utils.CoreUtils$.inReadLock(CoreUtils.scala:237)
      9. kafka.cluster.Partition.appendMessagesToLeader(Partition.scala:429)
      10. kafka.server.ReplicaManager$$anonfun$appendToLocalLog$2.apply(ReplicaManager.scala:406)
      11. kafka.server.ReplicaManager$$anonfun$appendToLocalLog$2.apply(ReplicaManager.scala:392)
      11 frames
    7. Scala
      AbstractTraversable.map
      1. scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234)
      2. scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234)
      3. scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:99)
      4. scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:99)
      5. scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:230)
      6. scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:40)
      7. scala.collection.mutable.HashMap.foreach(HashMap.scala:99)
      8. scala.collection.TraversableLike$class.map(TraversableLike.scala:234)
      9. scala.collection.AbstractTraversable.map(Traversable.scala:104)
      9 frames
    8. Apache Kafka
      KafkaRequestHandler.run
      1. kafka.server.ReplicaManager.appendToLocalLog(ReplicaManager.scala:392)
      2. kafka.server.ReplicaManager.appendMessages(ReplicaManager.scala:328)
      3. kafka.server.KafkaApis.handleProducerRequest(KafkaApis.scala:405)
      4. kafka.server.KafkaApis.handle(KafkaApis.scala:76)
      5. kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:60)
      5 frames
    9. Java RT
      Thread.run
      1. java.lang.Thread.run(Thread.java:745)
      1 frame