kafka.cluster.Broker

csdn.net | 8 months ago
tip
Your exception is missing from the Samebug knowledge base.
Here are the best solutions we found on the Internet.
Click on the to mark the helpful solution and get rewards for you help.

Root Cause Analysis

  1. kafka.cluster.Broker

    No message provided

    at org.apache.spark.streaming.kafka.KafkaCluster$$anonfun$2$$anonfun$3$$anonfun$apply$6$$anonfun$apply$7.apply()
  2. Spark Project External Kafka
    KafkaCluster$$anonfun$2$$anonfun$3$$anonfun$apply$6$$anonfun$apply$7.apply
    1. org.apache.spark.streaming.kafka.KafkaCluster$$anonfun$2$$anonfun$3$$anonfun$apply$6$$anonfun$apply$7.apply(KafkaCluster.scala:90)
    1 frame
  3. Scala
    Option.map
    1. scala.Option.map(Option.scala:145)
    1 frame
  4. Spark Project External Kafka
    KafkaCluster$$anonfun$2$$anonfun$3$$anonfun$apply$6.apply
    1. org.apache.spark.streaming.kafka.KafkaCluster$$anonfun$2$$anonfun$3$$anonfun$apply$6.apply(KafkaCluster.scala:90)
    2. org.apache.spark.streaming.kafka.KafkaCluster$$anonfun$2$$anonfun$3$$anonfun$apply$6.apply(KafkaCluster.scala:87)
    2 frames
  5. Scala
    AbstractTraversable.flatMap
    1. scala.collection.TraversableLike$$anonfun$flatMap$1.apply(TraversableLike.scala:251)
    2. scala.collection.TraversableLike$$anonfun$flatMap$1.apply(TraversableLike.scala:251)
    3. scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:33)
    4. scala.collection.mutable.WrappedArray.foreach(WrappedArray.scala:34)
    5. scala.collection.TraversableLike$class.flatMap(TraversableLike.scala:251)
    6. scala.collection.AbstractTraversable.flatMap(Traversable.scala:105)
    6 frames
  6. Spark Project External Kafka
    KafkaCluster$$anonfun$2$$anonfun$3.apply
    1. org.apache.spark.streaming.kafka.KafkaCluster$$anonfun$2$$anonfun$3.apply(KafkaCluster.scala:87)
    2. org.apache.spark.streaming.kafka.KafkaCluster$$anonfun$2$$anonfun$3.apply(KafkaCluster.scala:86)
    2 frames
  7. Scala
    AbstractTraversable.flatMap
    1. scala.collection.TraversableLike$$anonfun$flatMap$1.apply(TraversableLike.scala:251)
    2. scala.collection.TraversableLike$$anonfun$flatMap$1.apply(TraversableLike.scala:251)
    3. scala.collection.immutable.Set$Set1.foreach(Set.scala:74)
    4. scala.collection.TraversableLike$class.flatMap(TraversableLike.scala:251)
    5. scala.collection.AbstractTraversable.flatMap(Traversable.scala:105)
    5 frames
  8. Spark Project External Kafka
    KafkaCluster$$anonfun$2.apply
    1. org.apache.spark.streaming.kafka.KafkaCluster$$anonfun$2.apply(KafkaCluster.scala:86)
    2. org.apache.spark.streaming.kafka.KafkaCluster$$anonfun$2.apply(KafkaCluster.scala:85)
    2 frames
  9. Scala
    Either$RightProjection.flatMap
    1. scala.util.Either$RightProjection.flatMap(Either.scala:523)
    1 frame
  10. Spark Project External Kafka
    KafkaUtils$$anonfun$5.apply
    1. org.apache.spark.streaming.kafka.KafkaCluster.findLeaders(KafkaCluster.scala:85)
    2. org.apache.spark.streaming.kafka.KafkaCluster.getLeaderOffsets(KafkaCluster.scala:179)
    3. org.apache.spark.streaming.kafka.KafkaCluster.getLeaderOffsets(KafkaCluster.scala:161)
    4. org.apache.spark.streaming.kafka.KafkaCluster.getLatestLeaderOffsets(KafkaCluster.scala:150)
    5. org.apache.spark.streaming.kafka.KafkaUtils$$anonfun$5.apply(KafkaUtils.scala:215)
    6. org.apache.spark.streaming.kafka.KafkaUtils$$anonfun$5.apply(KafkaUtils.scala:211)
    6 frames
  11. Scala
    Either$RightProjection.flatMap
    1. scala.util.Either$RightProjection.flatMap(Either.scala:523)
    1 frame
  12. Spark Project External Kafka
    KafkaUtils.createDirectStream
    1. org.apache.spark.streaming.kafka.KafkaUtils$.getFromOffsets(KafkaUtils.scala:211)
    2. org.apache.spark.streaming.kafka.KafkaUtils$.createDirectStream(KafkaUtils.scala:484)
    3. org.apache.spark.streaming.kafka.KafkaUtils$.createDirectStream(KafkaUtils.scala:607)
    4. org.apache.spark.streaming.kafka.KafkaUtils.createDirectStream(KafkaUtils.scala)
    4 frames
  13. com.dt.spark
    SparkStreamingOnKafkaDirected.main
    1. com.dt.spark.SparkApps.SparkStreaming.SparkStreamingOnKafkaDirected.main(SparkStreamingOnKafkaDirected.java:68)
    1 frame
  14. Java RT
    Method.invoke
    1. sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    2. sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
    3. sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    4. java.lang.reflect.Method.invoke(Method.java:497)
    4 frames
  15. Spark
    SparkSubmit$.main
    1. org.apache.spark.deploy.SparkSubmit$.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:731)
    2. org.apache.spark.deploy.SparkSubmit$.doRunMain$1(SparkSubmit.scala:181)
    3. org.apache.spark.deploy.SparkSubmit$.submit(SparkSubmit.scala:206)
    4. org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:121)
    4 frames