com.datastax.spark.connector.types.TypeConversionException: Failed to convert column X of vassil_test.general_6 to java.lang.Long: null

DataStax JIRA | Vassil Lunchev | 1 year 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.
  1. 0

    Issue related to Connector 1.5.0-RC1. The same code was tested with Connecter 1.4.1 and it works fine. (see the 'Environment' field) When trying to read from a Cassandra table with CassandraJavaUtil.mapRowTo(): {code:java} JavaRDD<Iterable<General6>> shardSessions = CassandraJavaUtil .javaFunctions(context) .cassandraTable(LIVE_SESSIONS_KEYSPACE_NAME, LIVE_SESSIONS_TABLE_NAME, CassandraJavaUtil.mapRowTo(General6.class)) {code} It cannot map a nullable column with value null to java.lang.Long. {code:java} com.datastax.spark.connector.types.TypeConversionException: Failed to convert column X of vassil_test.general_6 to java.lang.Long: null at com.datastax.spark.connector.rdd.reader.GettableDataToMappedTypeConverter.tryConvert(GettableDataToMappedTypeConverter.scala:135) at com.datastax.spark.connector.rdd.reader.GettableDataToMappedTypeConverter.convertedColumnValue(GettableDataToMappedTypeConverter.scala:161) at com.datastax.spark.connector.rdd.reader.GettableDataToMappedTypeConverter.com$datastax$spark$connector$rdd$reader$GettableDataToMappedTypeConverter$$setterParamValue(GettableDataToMappedTypeConverter.scala:210) at com.datastax.spark.connector.rdd.reader.GettableDataToMappedTypeConverter$$anonfun$com$datastax$spark$connector$rdd$reader$GettableDataToMappedTypeConverter$$invokeSetters$2.apply(GettableDataToMappedTypeConverter.scala:250) at com.datastax.spark.connector.rdd.reader.GettableDataToMappedTypeConverter$$anonfun$com$datastax$spark$connector$rdd$reader$GettableDataToMappedTypeConverter$$invokeSetters$2.apply(GettableDataToMappedTypeConverter.scala:249) at scala.collection.TraversableLike$WithFilter$$anonfun$foreach$1.apply(TraversableLike.scala:772) at scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:33) at scala.collection.mutable.ArrayOps$ofRef.foreach(ArrayOps.scala:108) at scala.collection.TraversableLike$WithFilter.foreach(TraversableLike.scala:771) at com.datastax.spark.connector.rdd.reader.GettableDataToMappedTypeConverter.com$datastax$spark$connector$rdd$reader$GettableDataToMappedTypeConverter$$invokeSetters(GettableDataToMappedTypeConverter.scala:249) at com.datastax.spark.connector.rdd.reader.GettableDataToMappedTypeConverter$$anonfun$convertPF$1.applyOrElse(GettableDataToMappedTypeConverter.scala:263) at com.datastax.spark.connector.types.TypeConverter$class.convert(TypeConverter.scala:43) at com.datastax.spark.connector.rdd.reader.GettableDataToMappedTypeConverter.convert(GettableDataToMappedTypeConverter.scala:20) at com.datastax.spark.connector.rdd.reader.ClassBasedRowReader.read(ClassBasedRowReader.scala:37) at com.datastax.spark.connector.rdd.CassandraTableScanRDD$$anonfun$12.apply(CassandraTableScanRDD.scala:208) at com.datastax.spark.connector.rdd.CassandraTableScanRDD$$anonfun$12.apply(CassandraTableScanRDD.scala:208) at scala.collection.Iterator$$anon$11.next(Iterator.scala:328) at scala.collection.Iterator$$anon$13.next(Iterator.scala:372) at com.datastax.spark.connector.util.CountingIterator.next(CountingIterator.scala:16) at com.datastax.spark.connector.util.BufferedIterator2.advance(BufferedIterator2.scala:24) at com.datastax.spark.connector.util.BufferedIterator2.<init>(BufferedIterator2.scala:13) at com.datastax.spark.connector.util.SpanningIterator.<init>(SpanningIterator.scala:21) at com.datastax.spark.connector.rdd.SpannedRDD.compute(SpannedRDD.scala:29) at com.datastax.spark.connector.rdd.SpannedRDD.compute(SpannedRDD.scala:22) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:38) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:38) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:66) at org.apache.spark.scheduler.Task.run(Task.scala:88) at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:214) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at java.lang.Thread.run(Thread.java:745) Caused by: com.datastax.spark.connector.types.TypeConversionException: Cannot convert object null to java.lang.Long. at com.datastax.spark.connector.types.TypeConverter$$anonfun$convert$1.apply(TypeConverter.scala:47) at com.datastax.spark.connector.types.TypeConverter$$anonfun$convert$1.apply(TypeConverter.scala:43) at com.datastax.spark.connector.types.TypeConverter$TimeTypeConverter$$anonfun$convertPF$21.applyOrElse(TypeConverter.scala:458) at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:166) at com.datastax.spark.connector.types.TypeConverter$class.convert(TypeConverter.scala:43) at com.datastax.spark.connector.types.ChainedTypeConverter.convert(TypeConverter.scala:63) at com.datastax.spark.connector.rdd.reader.GettableDataToMappedTypeConverter.tryConvert(GettableDataToMappedTypeConverter.scala:132) ... 229 more {code}

    DataStax JIRA | 1 year ago | Vassil Lunchev
    com.datastax.spark.connector.types.TypeConversionException: Failed to convert column X of vassil_test.general_6 to java.lang.Long: null
  2. 0

    Issue related to Connector 1.5.0-RC1. The same code was tested with Connecter 1.4.1 and it works fine. (see the 'Environment' field) When trying to read from a Cassandra table with CassandraJavaUtil.mapRowTo(): {code:java} JavaRDD<Iterable<General6>> shardSessions = CassandraJavaUtil .javaFunctions(context) .cassandraTable(LIVE_SESSIONS_KEYSPACE_NAME, LIVE_SESSIONS_TABLE_NAME, CassandraJavaUtil.mapRowTo(General6.class)) {code} It cannot map a nullable column with value null to java.lang.Long. {code:java} com.datastax.spark.connector.types.TypeConversionException: Failed to convert column X of vassil_test.general_6 to java.lang.Long: null at com.datastax.spark.connector.rdd.reader.GettableDataToMappedTypeConverter.tryConvert(GettableDataToMappedTypeConverter.scala:135) at com.datastax.spark.connector.rdd.reader.GettableDataToMappedTypeConverter.convertedColumnValue(GettableDataToMappedTypeConverter.scala:161) at com.datastax.spark.connector.rdd.reader.GettableDataToMappedTypeConverter.com$datastax$spark$connector$rdd$reader$GettableDataToMappedTypeConverter$$setterParamValue(GettableDataToMappedTypeConverter.scala:210) at com.datastax.spark.connector.rdd.reader.GettableDataToMappedTypeConverter$$anonfun$com$datastax$spark$connector$rdd$reader$GettableDataToMappedTypeConverter$$invokeSetters$2.apply(GettableDataToMappedTypeConverter.scala:250) at com.datastax.spark.connector.rdd.reader.GettableDataToMappedTypeConverter$$anonfun$com$datastax$spark$connector$rdd$reader$GettableDataToMappedTypeConverter$$invokeSetters$2.apply(GettableDataToMappedTypeConverter.scala:249) at scala.collection.TraversableLike$WithFilter$$anonfun$foreach$1.apply(TraversableLike.scala:772) at scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:33) at scala.collection.mutable.ArrayOps$ofRef.foreach(ArrayOps.scala:108) at scala.collection.TraversableLike$WithFilter.foreach(TraversableLike.scala:771) at com.datastax.spark.connector.rdd.reader.GettableDataToMappedTypeConverter.com$datastax$spark$connector$rdd$reader$GettableDataToMappedTypeConverter$$invokeSetters(GettableDataToMappedTypeConverter.scala:249) at com.datastax.spark.connector.rdd.reader.GettableDataToMappedTypeConverter$$anonfun$convertPF$1.applyOrElse(GettableDataToMappedTypeConverter.scala:263) at com.datastax.spark.connector.types.TypeConverter$class.convert(TypeConverter.scala:43) at com.datastax.spark.connector.rdd.reader.GettableDataToMappedTypeConverter.convert(GettableDataToMappedTypeConverter.scala:20) at com.datastax.spark.connector.rdd.reader.ClassBasedRowReader.read(ClassBasedRowReader.scala:37) at com.datastax.spark.connector.rdd.CassandraTableScanRDD$$anonfun$12.apply(CassandraTableScanRDD.scala:208) at com.datastax.spark.connector.rdd.CassandraTableScanRDD$$anonfun$12.apply(CassandraTableScanRDD.scala:208) at scala.collection.Iterator$$anon$11.next(Iterator.scala:328) at scala.collection.Iterator$$anon$13.next(Iterator.scala:372) at com.datastax.spark.connector.util.CountingIterator.next(CountingIterator.scala:16) at com.datastax.spark.connector.util.BufferedIterator2.advance(BufferedIterator2.scala:24) at com.datastax.spark.connector.util.BufferedIterator2.<init>(BufferedIterator2.scala:13) at com.datastax.spark.connector.util.SpanningIterator.<init>(SpanningIterator.scala:21) at com.datastax.spark.connector.rdd.SpannedRDD.compute(SpannedRDD.scala:29) at com.datastax.spark.connector.rdd.SpannedRDD.compute(SpannedRDD.scala:22) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:38) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:38) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87) at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300) at org.apache.spark.rdd.RDD.iterator(RDD.scala:264) at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:66) at org.apache.spark.scheduler.Task.run(Task.scala:88) at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:214) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at java.lang.Thread.run(Thread.java:745) Caused by: com.datastax.spark.connector.types.TypeConversionException: Cannot convert object null to java.lang.Long. at com.datastax.spark.connector.types.TypeConverter$$anonfun$convert$1.apply(TypeConverter.scala:47) at com.datastax.spark.connector.types.TypeConverter$$anonfun$convert$1.apply(TypeConverter.scala:43) at com.datastax.spark.connector.types.TypeConverter$TimeTypeConverter$$anonfun$convertPF$21.applyOrElse(TypeConverter.scala:458) at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:166) at com.datastax.spark.connector.types.TypeConverter$class.convert(TypeConverter.scala:43) at com.datastax.spark.connector.types.ChainedTypeConverter.convert(TypeConverter.scala:63) at com.datastax.spark.connector.rdd.reader.GettableDataToMappedTypeConverter.tryConvert(GettableDataToMappedTypeConverter.scala:132) ... 229 more {code}

    DataStax JIRA | 1 year ago | Vassil Lunchev
    com.datastax.spark.connector.types.TypeConversionException: Failed to convert column X of vassil_test.general_6 to java.lang.Long: null

    1 unregistered visitors

    Root Cause Analysis

    1. com.datastax.spark.connector.types.TypeConversionException

      Cannot convert object null to java.lang.Long.

      at com.datastax.spark.connector.types.TypeConverter$$anonfun$convert$1.apply()
    2. spark-cassandra-connector
      TypeConverter$TimeTypeConverter$$anonfun$convertPF$21.applyOrElse
      1. com.datastax.spark.connector.types.TypeConverter$$anonfun$convert$1.apply(TypeConverter.scala:47)
      2. com.datastax.spark.connector.types.TypeConverter$$anonfun$convert$1.apply(TypeConverter.scala:43)
      3. com.datastax.spark.connector.types.TypeConverter$TimeTypeConverter$$anonfun$convertPF$21.applyOrElse(TypeConverter.scala:458)
      3 frames
    3. Scala
      PartialFunction$OrElse.applyOrElse
      1. scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:166)
      1 frame
    4. spark-cassandra-connector
      GettableDataToMappedTypeConverter$$anonfun$com$datastax$spark$connector$rdd$reader$GettableDataToMappedTypeConverter$$invokeSetters$2.apply
      1. com.datastax.spark.connector.types.TypeConverter$class.convert(TypeConverter.scala:43)
      2. com.datastax.spark.connector.types.ChainedTypeConverter.convert(TypeConverter.scala:63)
      3. com.datastax.spark.connector.rdd.reader.GettableDataToMappedTypeConverter.tryConvert(GettableDataToMappedTypeConverter.scala:132)
      4. com.datastax.spark.connector.rdd.reader.GettableDataToMappedTypeConverter.convertedColumnValue(GettableDataToMappedTypeConverter.scala:161)
      5. com.datastax.spark.connector.rdd.reader.GettableDataToMappedTypeConverter.com$datastax$spark$connector$rdd$reader$GettableDataToMappedTypeConverter$$setterParamValue(GettableDataToMappedTypeConverter.scala:210)
      6. com.datastax.spark.connector.rdd.reader.GettableDataToMappedTypeConverter$$anonfun$com$datastax$spark$connector$rdd$reader$GettableDataToMappedTypeConverter$$invokeSetters$2.apply(GettableDataToMappedTypeConverter.scala:250)
      7. com.datastax.spark.connector.rdd.reader.GettableDataToMappedTypeConverter$$anonfun$com$datastax$spark$connector$rdd$reader$GettableDataToMappedTypeConverter$$invokeSetters$2.apply(GettableDataToMappedTypeConverter.scala:249)
      7 frames
    5. Scala
      TraversableLike$WithFilter.foreach
      1. scala.collection.TraversableLike$WithFilter$$anonfun$foreach$1.apply(TraversableLike.scala:772)
      2. scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:33)
      3. scala.collection.mutable.ArrayOps$ofRef.foreach(ArrayOps.scala:108)
      4. scala.collection.TraversableLike$WithFilter.foreach(TraversableLike.scala:771)
      4 frames
    6. spark-cassandra-connector
      CassandraTableScanRDD$$anonfun$12.apply
      1. com.datastax.spark.connector.rdd.reader.GettableDataToMappedTypeConverter.com$datastax$spark$connector$rdd$reader$GettableDataToMappedTypeConverter$$invokeSetters(GettableDataToMappedTypeConverter.scala:249)
      2. com.datastax.spark.connector.rdd.reader.GettableDataToMappedTypeConverter$$anonfun$convertPF$1.applyOrElse(GettableDataToMappedTypeConverter.scala:263)
      3. com.datastax.spark.connector.types.TypeConverter$class.convert(TypeConverter.scala:43)
      4. com.datastax.spark.connector.rdd.reader.GettableDataToMappedTypeConverter.convert(GettableDataToMappedTypeConverter.scala:20)
      5. com.datastax.spark.connector.rdd.reader.ClassBasedRowReader.read(ClassBasedRowReader.scala:37)
      6. com.datastax.spark.connector.rdd.CassandraTableScanRDD$$anonfun$12.apply(CassandraTableScanRDD.scala:208)
      7. com.datastax.spark.connector.rdd.CassandraTableScanRDD$$anonfun$12.apply(CassandraTableScanRDD.scala:208)
      7 frames
    7. Scala
      Iterator$$anon$13.next
      1. scala.collection.Iterator$$anon$11.next(Iterator.scala:328)
      2. scala.collection.Iterator$$anon$13.next(Iterator.scala:372)
      2 frames
    8. spark-cassandra-connector
      SpannedRDD.compute
      1. com.datastax.spark.connector.util.CountingIterator.next(CountingIterator.scala:16)
      2. com.datastax.spark.connector.util.BufferedIterator2.advance(BufferedIterator2.scala:24)
      3. com.datastax.spark.connector.util.BufferedIterator2.<init>(BufferedIterator2.scala:13)
      4. com.datastax.spark.connector.util.SpanningIterator.<init>(SpanningIterator.scala:21)
      5. com.datastax.spark.connector.rdd.SpannedRDD.compute(SpannedRDD.scala:29)
      6. com.datastax.spark.connector.rdd.SpannedRDD.compute(SpannedRDD.scala:22)
      6 frames
    9. Spark
      Executor$TaskRunner.run
      1. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      2. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      3. org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:38)
      4. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      5. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      6. org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:38)
      7. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      8. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      9. org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87)
      10. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      11. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      12. org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87)
      13. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      14. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      15. org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87)
      16. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      17. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      18. org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87)
      19. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      20. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      21. org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87)
      22. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      23. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      24. org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87)
      25. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      26. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      27. org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87)
      28. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      29. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      30. org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87)
      31. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      32. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      33. org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87)
      34. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      35. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      36. org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87)
      37. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      38. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      39. org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87)
      40. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      41. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      42. org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87)
      43. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      44. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      45. org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87)
      46. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      47. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      48. org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87)
      49. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      50. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      51. org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87)
      52. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      53. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      54. org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87)
      55. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      56. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      57. org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87)
      58. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      59. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      60. org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87)
      61. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      62. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      63. org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87)
      64. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      65. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      66. org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87)
      67. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      68. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      69. org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87)
      70. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      71. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      72. org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87)
      73. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      74. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      75. org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87)
      76. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      77. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      78. org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87)
      79. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      80. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      81. org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87)
      82. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      83. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      84. org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87)
      85. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      86. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      87. org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87)
      88. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      89. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      90. org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87)
      91. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      92. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      93. org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87)
      94. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      95. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      96. org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87)
      97. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      98. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      99. org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87)
      100. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      101. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      102. org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87)
      103. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      104. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      105. org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87)
      106. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      107. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      108. org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87)
      109. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      110. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      111. org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87)
      112. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      113. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      114. org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87)
      115. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      116. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      117. org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87)
      118. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      119. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      120. org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87)
      121. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      122. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      123. org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87)
      124. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      125. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      126. org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87)
      127. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      128. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      129. org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87)
      130. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      131. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      132. org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87)
      133. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      134. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      135. org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87)
      136. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      137. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      138. org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87)
      139. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      140. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      141. org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87)
      142. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      143. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      144. org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87)
      145. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      146. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      147. org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87)
      148. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      149. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      150. org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87)
      151. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      152. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      153. org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87)
      154. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      155. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      156. org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87)
      157. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      158. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      159. org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87)
      160. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      161. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      162. org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87)
      163. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      164. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      165. org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87)
      166. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      167. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      168. org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87)
      169. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      170. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      171. org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87)
      172. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      173. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      174. org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87)
      175. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      176. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      177. org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87)
      178. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      179. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      180. org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87)
      181. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      182. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      183. org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87)
      184. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      185. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      186. org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87)
      187. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      188. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      189. org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87)
      190. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      191. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      192. org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87)
      193. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      194. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      195. org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87)
      196. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      197. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      198. org.apache.spark.rdd.UnionRDD.compute(UnionRDD.scala:87)
      199. org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:300)
      200. org.apache.spark.rdd.RDD.iterator(RDD.scala:264)
      201. org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:66)
      202. org.apache.spark.scheduler.Task.run(Task.scala:88)
      203. org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:214)
      203 frames
    10. 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