[jira] [Commented] (CASSANDRA-7198) CqlPagingRecordReader throws IllegalStateException
[ https://issues.apache.org/jira/browse/CASSANDRA-7198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13993398#comment-13993398 ] Brent Theisen commented on CASSANDRA-7198: -- Ahh, of course. Attached a patch that catches it. > CqlPagingRecordReader throws IllegalStateException > -- > > Key: CASSANDRA-7198 > URL: https://issues.apache.org/jira/browse/CASSANDRA-7198 > Project: Cassandra > Issue Type: Bug > Components: Hadoop > Environment: Spark with Calliope EA against Cassandra 2.0.7 >Reporter: Brent Theisen >Priority: Trivial > Fix For: 2.0.9 > > Attachments: trunk-7198-2.txt > > > Getting the following exception when running a Spark job that does *not* > specify cassandra.input.page.row.size: > {code} > 14/05/08 14:30:43 ERROR executor.Executor: Exception in task ID 12 > java.lang.IllegalStateException: Optional.get() cannot be called on an absent > value > at com.google.common.base.Absent.get(Absent.java:47) > at > org.apache.cassandra.hadoop.cql3.CqlPagingRecordReader.initialize(CqlPagingRecordReader.java:120) > at > com.tuplejump.calliope.cql3.Cql3CassandraRDD$$anon$1.(Cql3CassandraRDD.scala:65) > at > com.tuplejump.calliope.cql3.Cql3CassandraRDD.compute(Cql3CassandraRDD.scala:53) > at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:241) > at org.apache.spark.rdd.RDD.iterator(RDD.scala:232) > at org.apache.spark.rdd.MappedRDD.compute(MappedRDD.scala:31) > at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:241) > at org.apache.spark.rdd.RDD.iterator(RDD.scala:232) > at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:109) > at org.apache.spark.scheduler.Task.run(Task.scala:53) > at > org.apache.spark.executor.Executor$TaskRunner$$anonfun$run$1.apply$mcV$sp(Executor.scala:213) > at > org.apache.spark.deploy.SparkHadoopUtil.runAsUser(SparkHadoopUtil.scala:49) > at > org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:178) > at > java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) > at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) > at java.lang.Thread.run(Thread.java:744) > 14/05/08 14:30:43 ERROR executor.Executor: Exception in task ID 21 > java.lang.IllegalStateException: Optional.get() cannot be called on an absent > value > at com.google.common.base.Absent.get(Absent.java:47) > at > org.apache.cassandra.hadoop.cql3.CqlPagingRecordReader.initialize(CqlPagingRecordReader.java:120) > at > com.tuplejump.calliope.cql3.Cql3CassandraRDD$$anon$1.(Cql3CassandraRDD.scala:65) > at > com.tuplejump.calliope.cql3.Cql3CassandraRDD.compute(Cql3CassandraRDD.scala:53) > at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:241) > at org.apache.spark.rdd.RDD.iterator(RDD.scala:232) > at org.apache.spark.rdd.MappedRDD.compute(MappedRDD.scala:31) > at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:241) > at org.apache.spark.rdd.RDD.iterator(RDD.scala:232) > at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:109) > at org.apache.spark.scheduler.Task.run(Task.scala:53) > at > org.apache.spark.executor.Executor$TaskRunner$$anonfun$run$1.apply$mcV$sp(Executor.scala:213) > at > org.apache.spark.deploy.SparkHadoopUtil.runAsUser(SparkHadoopUtil.scala:49) > at > org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:178) > at > java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) > at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) > at java.lang.Thread.run(Thread.java:744) > {code} > Reason why is CqlPagingRecordReader catching the wrong exception type. Patch > attached. -- This message was sent by Atlassian JIRA (v6.2#6252)
[jira] [Updated] (CASSANDRA-7198) CqlPagingRecordReader throws IllegalStateException
[ https://issues.apache.org/jira/browse/CASSANDRA-7198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Brent Theisen updated CASSANDRA-7198: - Attachment: (was: trunk-7198.txt) > CqlPagingRecordReader throws IllegalStateException > -- > > Key: CASSANDRA-7198 > URL: https://issues.apache.org/jira/browse/CASSANDRA-7198 > Project: Cassandra > Issue Type: Bug > Components: Hadoop > Environment: Spark with Calliope EA against Cassandra 2.0.7 >Reporter: Brent Theisen >Priority: Trivial > Fix For: 2.0.9 > > Attachments: trunk-7198-2.txt > > > Getting the following exception when running a Spark job that does *not* > specify cassandra.input.page.row.size: > {code} > 14/05/08 14:30:43 ERROR executor.Executor: Exception in task ID 12 > java.lang.IllegalStateException: Optional.get() cannot be called on an absent > value > at com.google.common.base.Absent.get(Absent.java:47) > at > org.apache.cassandra.hadoop.cql3.CqlPagingRecordReader.initialize(CqlPagingRecordReader.java:120) > at > com.tuplejump.calliope.cql3.Cql3CassandraRDD$$anon$1.(Cql3CassandraRDD.scala:65) > at > com.tuplejump.calliope.cql3.Cql3CassandraRDD.compute(Cql3CassandraRDD.scala:53) > at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:241) > at org.apache.spark.rdd.RDD.iterator(RDD.scala:232) > at org.apache.spark.rdd.MappedRDD.compute(MappedRDD.scala:31) > at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:241) > at org.apache.spark.rdd.RDD.iterator(RDD.scala:232) > at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:109) > at org.apache.spark.scheduler.Task.run(Task.scala:53) > at > org.apache.spark.executor.Executor$TaskRunner$$anonfun$run$1.apply$mcV$sp(Executor.scala:213) > at > org.apache.spark.deploy.SparkHadoopUtil.runAsUser(SparkHadoopUtil.scala:49) > at > org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:178) > at > java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) > at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) > at java.lang.Thread.run(Thread.java:744) > 14/05/08 14:30:43 ERROR executor.Executor: Exception in task ID 21 > java.lang.IllegalStateException: Optional.get() cannot be called on an absent > value > at com.google.common.base.Absent.get(Absent.java:47) > at > org.apache.cassandra.hadoop.cql3.CqlPagingRecordReader.initialize(CqlPagingRecordReader.java:120) > at > com.tuplejump.calliope.cql3.Cql3CassandraRDD$$anon$1.(Cql3CassandraRDD.scala:65) > at > com.tuplejump.calliope.cql3.Cql3CassandraRDD.compute(Cql3CassandraRDD.scala:53) > at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:241) > at org.apache.spark.rdd.RDD.iterator(RDD.scala:232) > at org.apache.spark.rdd.MappedRDD.compute(MappedRDD.scala:31) > at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:241) > at org.apache.spark.rdd.RDD.iterator(RDD.scala:232) > at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:109) > at org.apache.spark.scheduler.Task.run(Task.scala:53) > at > org.apache.spark.executor.Executor$TaskRunner$$anonfun$run$1.apply$mcV$sp(Executor.scala:213) > at > org.apache.spark.deploy.SparkHadoopUtil.runAsUser(SparkHadoopUtil.scala:49) > at > org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:178) > at > java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) > at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) > at java.lang.Thread.run(Thread.java:744) > {code} > Reason why is CqlPagingRecordReader catching the wrong exception type. Patch > attached. -- This message was sent by Atlassian JIRA (v6.2#6252)
[jira] [Updated] (CASSANDRA-7198) CqlPagingRecordReader throws IllegalStateException
[ https://issues.apache.org/jira/browse/CASSANDRA-7198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Brent Theisen updated CASSANDRA-7198: - Attachment: trunk-7198-2.txt > CqlPagingRecordReader throws IllegalStateException > -- > > Key: CASSANDRA-7198 > URL: https://issues.apache.org/jira/browse/CASSANDRA-7198 > Project: Cassandra > Issue Type: Bug > Components: Hadoop > Environment: Spark with Calliope EA against Cassandra 2.0.7 >Reporter: Brent Theisen >Priority: Trivial > Fix For: 2.0.9 > > Attachments: trunk-7198-2.txt > > > Getting the following exception when running a Spark job that does *not* > specify cassandra.input.page.row.size: > {code} > 14/05/08 14:30:43 ERROR executor.Executor: Exception in task ID 12 > java.lang.IllegalStateException: Optional.get() cannot be called on an absent > value > at com.google.common.base.Absent.get(Absent.java:47) > at > org.apache.cassandra.hadoop.cql3.CqlPagingRecordReader.initialize(CqlPagingRecordReader.java:120) > at > com.tuplejump.calliope.cql3.Cql3CassandraRDD$$anon$1.(Cql3CassandraRDD.scala:65) > at > com.tuplejump.calliope.cql3.Cql3CassandraRDD.compute(Cql3CassandraRDD.scala:53) > at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:241) > at org.apache.spark.rdd.RDD.iterator(RDD.scala:232) > at org.apache.spark.rdd.MappedRDD.compute(MappedRDD.scala:31) > at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:241) > at org.apache.spark.rdd.RDD.iterator(RDD.scala:232) > at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:109) > at org.apache.spark.scheduler.Task.run(Task.scala:53) > at > org.apache.spark.executor.Executor$TaskRunner$$anonfun$run$1.apply$mcV$sp(Executor.scala:213) > at > org.apache.spark.deploy.SparkHadoopUtil.runAsUser(SparkHadoopUtil.scala:49) > at > org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:178) > at > java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) > at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) > at java.lang.Thread.run(Thread.java:744) > 14/05/08 14:30:43 ERROR executor.Executor: Exception in task ID 21 > java.lang.IllegalStateException: Optional.get() cannot be called on an absent > value > at com.google.common.base.Absent.get(Absent.java:47) > at > org.apache.cassandra.hadoop.cql3.CqlPagingRecordReader.initialize(CqlPagingRecordReader.java:120) > at > com.tuplejump.calliope.cql3.Cql3CassandraRDD$$anon$1.(Cql3CassandraRDD.scala:65) > at > com.tuplejump.calliope.cql3.Cql3CassandraRDD.compute(Cql3CassandraRDD.scala:53) > at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:241) > at org.apache.spark.rdd.RDD.iterator(RDD.scala:232) > at org.apache.spark.rdd.MappedRDD.compute(MappedRDD.scala:31) > at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:241) > at org.apache.spark.rdd.RDD.iterator(RDD.scala:232) > at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:109) > at org.apache.spark.scheduler.Task.run(Task.scala:53) > at > org.apache.spark.executor.Executor$TaskRunner$$anonfun$run$1.apply$mcV$sp(Executor.scala:213) > at > org.apache.spark.deploy.SparkHadoopUtil.runAsUser(SparkHadoopUtil.scala:49) > at > org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:178) > at > java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) > at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) > at java.lang.Thread.run(Thread.java:744) > {code} > Reason why is CqlPagingRecordReader catching the wrong exception type. Patch > attached. -- This message was sent by Atlassian JIRA (v6.2#6252)