[jira] [Updated] (CASSANDRA-7198) CqlPagingRecordReader throws IllegalStateException

2014-05-15 Thread Brent Theisen (JIRA) 

 [ 
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

2014-05-15 Thread Brent Theisen (JIRA) 

 [ 
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)

[jira] [Updated] (CASSANDRA-7198) CqlPagingRecordReader throws IllegalStateException

2014-05-15 Thread Jonathan Ellis (JIRA) 

 [ 
https://issues.apache.org/jira/browse/CASSANDRA-7198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Jonathan Ellis updated CASSANDRA-7198:
--

Reviewer: Dave Brosius
Assignee: Brent Theisen

> 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
>Assignee: 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)