java.util.NoSuchElementException: key not found: node

spark-user | java8964 | 2 years ago
tip
Do you know that we can give you better hits? Get more relevant results from Samebug’s stack trace search.
  1. Speed up your debug routine!

    Automated exception search integrated into your IDE

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.util.NoSuchElementException

    key not found: node

    at scala.collection.MapLike$class.default()
  2. Scala
    AbstractMap.apply
    1. scala.collection.MapLike$class.default(MapLike.scala:228)
    2. scala.collection.AbstractMap.default(Map.scala:58)
    3. scala.collection.MapLike$class.apply(MapLike.scala:141)
    4. scala.collection.AbstractMap.apply(Map.scala:58)
    4 frames
  3. Elasticsearch Spark
    ScalaRowValueReader.addToMap
    1. org.elasticsearch.spark.sql.RowValueReader$class.addToBuffer(RowValueReader.scala:32)
    2. org.elasticsearch.spark.sql.ScalaRowValueReader.addToBuffer(ScalaRowValueReader.scala:9)
    3. org.elasticsearch.spark.sql.ScalaRowValueReader.addToMap(ScalaRowValueReader.scala:16)
    3 frames
  4. Elasticsearch Hadoop
    ScrollQuery.hasNext
    1. org.elasticsearch.hadoop.serialization.ScrollReader.map(ScrollReader.java:596)
    2. org.elasticsearch.hadoop.serialization.ScrollReader.read(ScrollReader.java:519)
    3. org.elasticsearch.hadoop.serialization.ScrollReader.list(ScrollReader.java:560)
    4. org.elasticsearch.hadoop.serialization.ScrollReader.read(ScrollReader.java:522)
    5. org.elasticsearch.hadoop.serialization.ScrollReader.map(ScrollReader.java:596)
    6. org.elasticsearch.hadoop.serialization.ScrollReader.read(ScrollReader.java:519)
    7. org.elasticsearch.hadoop.serialization.ScrollReader.readHitAsMap(ScrollReader.java:339)
    8. org.elasticsearch.hadoop.serialization.ScrollReader.readHit(ScrollReader.java:290)
    9. org.elasticsearch.hadoop.serialization.ScrollReader.read(ScrollReader.java:186)
    10. org.elasticsearch.hadoop.serialization.ScrollReader.read(ScrollReader.java:165)
    11. org.elasticsearch.hadoop.rest.RestRepository.scroll(RestRepository.java:403)
    12. org.elasticsearch.hadoop.rest.ScrollQuery.hasNext(ScrollQuery.java:76)
    12 frames
  5. Elasticsearch Spark
    AbstractEsRDDIterator.hasNext
    1. org.elasticsearch.spark.rdd.AbstractEsRDDIterator.hasNext(AbstractEsRDDIterator.scala:46)
    1 frame
  6. Scala
    AbstractIterator.toArray
    1. scala.collection.Iterator$$anon$11.hasNext(Iterator.scala:327)
    2. scala.collection.Iterator$class.foreach(Iterator.scala:727)
    3. scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
    4. scala.collection.generic.Growable$class.$plus$plus$eq(Growable.scala:48)
    5. scala.collection.mutable.ArrayBuffer.$plus$plus$eq(ArrayBuffer.scala:103)
    6. scala.collection.mutable.ArrayBuffer.$plus$plus$eq(ArrayBuffer.scala:47)
    7. scala.collection.TraversableOnce$class.to(TraversableOnce.scala:273)
    8. scala.collection.AbstractIterator.to(Iterator.scala:1157)
    9. scala.collection.TraversableOnce$class.toBuffer(TraversableOnce.scala:265)
    10. scala.collection.AbstractIterator.toBuffer(Iterator.scala:1157)
    11. scala.collection.TraversableOnce$class.toArray(TraversableOnce.scala:252)
    12. scala.collection.AbstractIterator.toArray(Iterator.scala:1157)
    12 frames
  7. Spark
    Executor$TaskRunner.run
    1. org.apache.spark.rdd.RDD$$anonfun$17.apply(RDD.scala:797)
    2. org.apache.spark.rdd.RDD$$anonfun$17.apply(RDD.scala:797)
    3. org.apache.spark.SparkContext$$anonfun$runJob$4.apply(SparkContext.scala:1353)
    4. org.apache.spark.SparkContext$$anonfun$runJob$4.apply(SparkContext.scala:1353)
    5. org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:61)
    6. org.apache.spark.scheduler.Task.run(Task.scala:56)
    7. org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:200)
    7 frames
  8. Java RT
    Thread.run
    1. java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
    2. java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
    3. java.lang.Thread.run(Thread.java:745)
    3 frames