org.apache.spark.SparkException: Couldn't find leader offsets for Set([test2,0])

Stack Overflow | user1849773 | 7 months ago
Do you know that we can give you better hits? Get more relevant results from Samebug’s stack trace search.
  1. 0

    Connection spark streaming to kafka within eclipse: error-Couldn't find leader offsets

    Stack Overflow | 7 months ago | user1849773
    org.apache.spark.SparkException: Couldn't find leader offsets for Set([test2,0])
  2. 0

    第91课:SparkStreaming基于Kafka Direct案例实战和内幕源码解密 java.lang.ClassNotFoundException 踩坑解决问题详细内幕版本 | 10 months ago
    org.apache.spark.SparkException: Error getting partition metadata for 'SparkStreamingDirected'. Does the topic  exist?
  3. 0

    GitHub comment 113#158861911

    GitHub | 1 year ago | ssamynathan
    org.apache.spark.SparkException: Received -1 when reading from channel, socket has likely been closed.
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

  5. 0

    Spark Streaming Kafka Consumer

    Stack Overflow | 5 months ago | Ken Alton

    6 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. org.apache.spark.SparkException

      Couldn't find leader offsets for Set([test2,0])

      at org.apache.spark.streaming.kafka.KafkaCluster$$anonfun$checkErrors$1.apply()
    2. Spark Project External Kafka
      1. org.apache.spark.streaming.kafka.KafkaCluster$$anonfun$checkErrors$1.apply(KafkaCluster.scala:373)
      2. org.apache.spark.streaming.kafka.KafkaCluster$$anonfun$checkErrors$1.apply(KafkaCluster.scala:373)
      2 frames
    3. Scala
      1. scala.util.Either.fold(Either.scala:98)
      1 frame
    4. Spark Project External Kafka
      1. org.apache.spark.streaming.kafka.KafkaCluster$.checkErrors(KafkaCluster.scala:372)
      2. org.apache.spark.streaming.kafka.KafkaUtils$.getFromOffsets(KafkaUtils.scala:222)
      3. org.apache.spark.streaming.kafka.KafkaUtils$.createDirectStream(KafkaUtils.scala:484)
      4. org.apache.spark.streaming.kafka.KafkaUtils$.createDirectStream(KafkaUtils.scala:607)
      5. org.apache.spark.streaming.kafka.KafkaUtils.createDirectStream(KafkaUtils.scala)
      5 frames
    5. sparkstreamingtest
      1. sparkstreamingtest.test1.main(
      1 frame