API tools faq
paste
Guest User

Untitled

a guest
Jul 27th, 2016
97
0
Never
Add comment
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 22.21 KB | None | 0 0
raw download clone embed print report
  1. 11:20:33 ERROR org.apache.spark.executor.Executor - Exception in task 3.0 in stage 0.0 (TID 3)
  2. java.lang.RuntimeException: error communicating via Thrift
  3. at org.apache.cassandra.hadoop.ColumnFamilyRecordReader$RowIterator.<init>(ColumnFamilyRecordReader.java:267)
  4. at org.apache.cassandra.hadoop.ColumnFamilyRecordReader$RowIterator.<init>(ColumnFamilyRecordReader.java:215)
  5. at org.apache.cassandra.hadoop.ColumnFamilyRecordReader$StaticRowIterator.<init>(ColumnFamilyRecordReader.java:331)
  6. at org.apache.cassandra.hadoop.ColumnFamilyRecordReader$StaticRowIterator.<init>(ColumnFamilyRecordReader.java:331)
  7. at org.apache.cassandra.hadoop.ColumnFamilyRecordReader.initialize(ColumnFamilyRecordReader.java:171)
  8. at com.thinkaurelius.titan.hadoop.formats.cassandra.CassandraBinaryRecordReader.initialize(CassandraBinaryRecordReader.java:39)
  9. at com.thinkaurelius.titan.hadoop.formats.util.GiraphRecordReader.initialize(GiraphRecordReader.java:38)
  10. at org.apache.spark.rdd.NewHadoopRDD$$anon$1.<init>(NewHadoopRDD.scala:135)
  11. at org.apache.spark.rdd.NewHadoopRDD.compute(NewHadoopRDD.scala:107)
  12. at org.apache.spark.rdd.NewHadoopRDD.compute(NewHadoopRDD.scala:69)
  13. at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:280)
  14. at org.apache.spark.rdd.RDD.iterator(RDD.scala:247)
  15. at org.apache.spark.rdd.MappedRDD.compute(MappedRDD.scala:31)
  16. at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:280)
  17. at org.apache.spark.rdd.RDD.iterator(RDD.scala:247)
  18. at org.apache.spark.scheduler.ShuffleMapTask.runTask(ShuffleMapTask.scala:68)
  19. at org.apache.spark.scheduler.ShuffleMapTask.runTask(ShuffleMapTask.scala:41)
  20. at org.apache.spark.scheduler.Task.run(Task.scala:56)
  21. at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:200)
  22. at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
  23. at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
  24. at java.lang.Thread.run(Thread.java:745)
  25. Caused by: InvalidRequestException(why:unconfigured table schema_columnfamilies)
  26. at org.apache.cassandra.thrift.Cassandra$execute_cql3_query_result$execute_cql3_query_resultStandardScheme.read(Cassandra.java:50297)
  27. at org.apache.cassandra.thrift.Cassandra$execute_cql3_query_result$execute_cql3_query_resultStandardScheme.read(Cassandra.java:50274)
  28. at org.apache.cassandra.thrift.Cassandra$execute_cql3_query_result.read(Cassandra.java:50189)
  29. at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:78)
  30. at org.apache.cassandra.thrift.Cassandra$Client.recv_execute_cql3_query(Cassandra.java:1734)
  31. at org.apache.cassandra.thrift.Cassandra$Client.execute_cql3_query(Cassandra.java:1719)
  32. at org.apache.cassandra.hadoop.ColumnFamilyRecordReader$RowIterator.<init>(ColumnFamilyRecordReader.java:238)
  33. ... 21 more
  34. 11:20:33 WARN org.apache.spark.scheduler.TaskSetManager - Lost task 3.0 in stage 0.0 (TID 3, localhost): java.lang.RuntimeException: error communicating via Thrift
  35. at org.apache.cassandra.hadoop.ColumnFamilyRecordReader$RowIterator.<init>(ColumnFamilyRecordReader.java:267)
  36. at org.apache.cassandra.hadoop.ColumnFamilyRecordReader$RowIterator.<init>(ColumnFamilyRecordReader.java:215)
  37. at org.apache.cassandra.hadoop.ColumnFamilyRecordReader$StaticRowIterator.<init>(ColumnFamilyRecordReader.java:331)
  38. at org.apache.cassandra.hadoop.ColumnFamilyRecordReader$StaticRowIterator.<init>(ColumnFamilyRecordReader.java:331)
  39. at org.apache.cassandra.hadoop.ColumnFamilyRecordReader.initialize(ColumnFamilyRecordReader.java:171)
  40. at com.thinkaurelius.titan.hadoop.formats.cassandra.CassandraBinaryRecordReader.initialize(CassandraBinaryRecordReader.java:39)
  41. at com.thinkaurelius.titan.hadoop.formats.util.GiraphRecordReader.initialize(GiraphRecordReader.java:38)
  42. at org.apache.spark.rdd.NewHadoopRDD$$anon$1.<init>(NewHadoopRDD.scala:135)
  43. at org.apache.spark.rdd.NewHadoopRDD.compute(NewHadoopRDD.scala:107)
  44. at org.apache.spark.rdd.NewHadoopRDD.compute(NewHadoopRDD.scala:69)
  45. at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:280)
  46. at org.apache.spark.rdd.RDD.iterator(RDD.scala:247)
  47. at org.apache.spark.rdd.MappedRDD.compute(MappedRDD.scala:31)
  48. at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:280)
  49. at org.apache.spark.rdd.RDD.iterator(RDD.scala:247)
  50. at org.apache.spark.scheduler.ShuffleMapTask.runTask(ShuffleMapTask.scala:68)
  51. at org.apache.spark.scheduler.ShuffleMapTask.runTask(ShuffleMapTask.scala:41)
  52. at org.apache.spark.scheduler.Task.run(Task.scala:56)
  53. at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:200)
  54. at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
  55. at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
  56. at java.lang.Thread.run(Thread.java:745)
  57. Caused by: InvalidRequestException(why:unconfigured table schema_columnfamilies)
  58. at org.apache.cassandra.thrift.Cassandra$execute_cql3_query_result$execute_cql3_query_resultStandardScheme.read(Cassandra.java:50297)
  59. at org.apache.cassandra.thrift.Cassandra$execute_cql3_query_result$execute_cql3_query_resultStandardScheme.read(Cassandra.java:50274)
  60. at org.apache.cassandra.thrift.Cassandra$execute_cql3_query_result.read(Cassandra.java:50189)
  61. at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:78)
  62. at org.apache.cassandra.thrift.Cassandra$Client.recv_execute_cql3_query(Cassandra.java:1734)
  63. at org.apache.cassandra.thrift.Cassandra$Client.execute_cql3_query(Cassandra.java:1719)
  64. at org.apache.cassandra.hadoop.ColumnFamilyRecordReader$RowIterator.<init>(ColumnFamilyRecordReader.java:238)
  65. ... 21 more
  66.  
  67. 11:20:33 ERROR org.apache.spark.scheduler.TaskSetManager - Task 3 in stage 0.0 failed 1 times; aborting job
  68. 11:20:33 ERROR org.apache.spark.executor.Executor - Exception in task 1.0 in stage 0.0 (TID 1)
  69. java.lang.RuntimeException: error communicating via Thrift
  70. at org.apache.cassandra.hadoop.ColumnFamilyRecordReader$RowIterator.<init>(ColumnFamilyRecordReader.java:267)
  71. at org.apache.cassandra.hadoop.ColumnFamilyRecordReader$RowIterator.<init>(ColumnFamilyRecordReader.java:215)
  72. at org.apache.cassandra.hadoop.ColumnFamilyRecordReader$StaticRowIterator.<init>(ColumnFamilyRecordReader.java:331)
  73. at org.apache.cassandra.hadoop.ColumnFamilyRecordReader$StaticRowIterator.<init>(ColumnFamilyRecordReader.java:331)
  74. at org.apache.cassandra.hadoop.ColumnFamilyRecordReader.initialize(ColumnFamilyRecordReader.java:171)
  75. at com.thinkaurelius.titan.hadoop.formats.cassandra.CassandraBinaryRecordReader.initialize(CassandraBinaryRecordReader.java:39)
  76. at com.thinkaurelius.titan.hadoop.formats.util.GiraphRecordReader.initialize(GiraphRecordReader.java:38)
  77. at org.apache.spark.rdd.NewHadoopRDD$$anon$1.<init>(NewHadoopRDD.scala:135)
  78. at org.apache.spark.rdd.NewHadoopRDD.compute(NewHadoopRDD.scala:107)
  79. at org.apache.spark.rdd.NewHadoopRDD.compute(NewHadoopRDD.scala:69)
  80. at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:280)
  81. at org.apache.spark.rdd.RDD.iterator(RDD.scala:247)
  82. at org.apache.spark.rdd.MappedRDD.compute(MappedRDD.scala:31)
  83. at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:280)
  84. at org.apache.spark.rdd.RDD.iterator(RDD.scala:247)
  85. at org.apache.spark.scheduler.ShuffleMapTask.runTask(ShuffleMapTask.scala:68)
  86. at org.apache.spark.scheduler.ShuffleMapTask.runTask(ShuffleMapTask.scala:41)
  87. at org.apache.spark.scheduler.Task.run(Task.scala:56)
  88. at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:200)
  89. at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
  90. at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
  91. at java.lang.Thread.run(Thread.java:745)
  92. Caused by: InvalidRequestException(why:unconfigured table schema_columnfamilies)
  93. at org.apache.cassandra.thrift.Cassandra$execute_cql3_query_result$execute_cql3_query_resultStandardScheme.read(Cassandra.java:50297)
  94. at org.apache.cassandra.thrift.Cassandra$execute_cql3_query_result$execute_cql3_query_resultStandardScheme.read(Cassandra.java:50274)
  95. at org.apache.cassandra.thrift.Cassandra$execute_cql3_query_result.read(Cassandra.java:50189)
  96. at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:78)
  97. at org.apache.cassandra.thrift.Cassandra$Client.recv_execute_cql3_query(Cassandra.java:1734)
  98. at org.apache.cassandra.thrift.Cassandra$Client.execute_cql3_query(Cassandra.java:1719)
  99. at org.apache.cassandra.hadoop.ColumnFamilyRecordReader$RowIterator.<init>(ColumnFamilyRecordReader.java:238)
  100. ... 21 more
  101. 11:20:33 ERROR org.apache.spark.executor.Executor - Exception in task 0.0 in stage 0.0 (TID 0)
  102. java.lang.RuntimeException: error communicating via Thrift
  103. at org.apache.cassandra.hadoop.ColumnFamilyRecordReader$RowIterator.<init>(ColumnFamilyRecordReader.java:267)
  104. at org.apache.cassandra.hadoop.ColumnFamilyRecordReader$RowIterator.<init>(ColumnFamilyRecordReader.java:215)
  105. at org.apache.cassandra.hadoop.ColumnFamilyRecordReader$StaticRowIterator.<init>(ColumnFamilyRecordReader.java:331)
  106. at org.apache.cassandra.hadoop.ColumnFamilyRecordReader$StaticRowIterator.<init>(ColumnFamilyRecordReader.java:331)
  107. at org.apache.cassandra.hadoop.ColumnFamilyRecordReader.initialize(ColumnFamilyRecordReader.java:171)
  108. at com.thinkaurelius.titan.hadoop.formats.cassandra.CassandraBinaryRecordReader.initialize(CassandraBinaryRecordReader.java:39)
  109. at com.thinkaurelius.titan.hadoop.formats.util.GiraphRecordReader.initialize(GiraphRecordReader.java:38)
  110. at org.apache.spark.rdd.NewHadoopRDD$$anon$1.<init>(NewHadoopRDD.scala:135)
  111. at org.apache.spark.rdd.NewHadoopRDD.compute(NewHadoopRDD.scala:107)
  112. at org.apache.spark.rdd.NewHadoopRDD.compute(NewHadoopRDD.scala:69)
  113. at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:280)
  114. at org.apache.spark.rdd.RDD.iterator(RDD.scala:247)
  115. at org.apache.spark.rdd.MappedRDD.compute(MappedRDD.scala:31)
  116. at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:280)
  117. at org.apache.spark.rdd.RDD.iterator(RDD.scala:247)
  118. at org.apache.spark.scheduler.ShuffleMapTask.runTask(ShuffleMapTask.scala:68)
  119. at org.apache.spark.scheduler.ShuffleMapTask.runTask(ShuffleMapTask.scala:41)
  120. at org.apache.spark.scheduler.Task.run(Task.scala:56)
  121. at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:200)
  122. at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
  123. at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
  124. at java.lang.Thread.run(Thread.java:745)
  125. Caused by: InvalidRequestException(why:unconfigured table schema_columnfamilies)
  126. at org.apache.cassandra.thrift.Cassandra$execute_cql3_query_result$execute_cql3_query_resultStandardScheme.read(Cassandra.java:50297)
  127. at org.apache.cassandra.thrift.Cassandra$execute_cql3_query_result$execute_cql3_query_resultStandardScheme.read(Cassandra.java:50274)
  128. at org.apache.cassandra.thrift.Cassandra$execute_cql3_query_result.read(Cassandra.java:50189)
  129. at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:78)
  130. at org.apache.cassandra.thrift.Cassandra$Client.recv_execute_cql3_query(Cassandra.java:1734)
  131. at org.apache.cassandra.thrift.Cassandra$Client.execute_cql3_query(Cassandra.java:1719)
  132. at org.apache.cassandra.hadoop.ColumnFamilyRecordReader$RowIterator.<init>(ColumnFamilyRecordReader.java:238)
  133. ... 21 more
  134. 11:20:33 ERROR org.apache.spark.executor.Executor - Exception in task 2.0 in stage 0.0 (TID 2)
  135. java.lang.RuntimeException: error communicating via Thrift
  136. at org.apache.cassandra.hadoop.ColumnFamilyRecordReader$RowIterator.<init>(ColumnFamilyRecordReader.java:267)
  137. at org.apache.cassandra.hadoop.ColumnFamilyRecordReader$RowIterator.<init>(ColumnFamilyRecordReader.java:215)
  138. at org.apache.cassandra.hadoop.ColumnFamilyRecordReader$StaticRowIterator.<init>(ColumnFamilyRecordReader.java:331)
  139. at org.apache.cassandra.hadoop.ColumnFamilyRecordReader$StaticRowIterator.<init>(ColumnFamilyRecordReader.java:331)
  140. at org.apache.cassandra.hadoop.ColumnFamilyRecordReader.initialize(ColumnFamilyRecordReader.java:171)
  141. at com.thinkaurelius.titan.hadoop.formats.cassandra.CassandraBinaryRecordReader.initialize(CassandraBinaryRecordReader.java:39)
  142. at com.thinkaurelius.titan.hadoop.formats.util.GiraphRecordReader.initialize(GiraphRecordReader.java:38)
  143. at org.apache.spark.rdd.NewHadoopRDD$$anon$1.<init>(NewHadoopRDD.scala:135)
  144. at org.apache.spark.rdd.NewHadoopRDD.compute(NewHadoopRDD.scala:107)
  145. at org.apache.spark.rdd.NewHadoopRDD.compute(NewHadoopRDD.scala:69)
  146. at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:280)
  147. at org.apache.spark.rdd.RDD.iterator(RDD.scala:247)
  148. at org.apache.spark.rdd.MappedRDD.compute(MappedRDD.scala:31)
  149. at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:280)
  150. at org.apache.spark.rdd.RDD.iterator(RDD.scala:247)
  151. at org.apache.spark.scheduler.ShuffleMapTask.runTask(ShuffleMapTask.scala:68)
  152. at org.apache.spark.scheduler.ShuffleMapTask.runTask(ShuffleMapTask.scala:41)
  153. at org.apache.spark.scheduler.Task.run(Task.scala:56)
  154. at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:200)
  155. at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
  156. at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
  157. at java.lang.Thread.run(Thread.java:745)
  158. Caused by: InvalidRequestException(why:unconfigured table schema_columnfamilies)
  159. at org.apache.cassandra.thrift.Cassandra$execute_cql3_query_result$execute_cql3_query_resultStandardScheme.read(Cassandra.java:50297)
  160. at org.apache.cassandra.thrift.Cassandra$execute_cql3_query_result$execute_cql3_query_resultStandardScheme.read(Cassandra.java:50274)
  161. at org.apache.cassandra.thrift.Cassandra$execute_cql3_query_result.read(Cassandra.java:50189)
  162. at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:78)
  163. at org.apache.cassandra.thrift.Cassandra$Client.recv_execute_cql3_query(Cassandra.java:1734)
  164. at org.apache.cassandra.thrift.Cassandra$Client.execute_cql3_query(Cassandra.java:1719)
  165. at org.apache.cassandra.hadoop.ColumnFamilyRecordReader$RowIterator.<init>(ColumnFamilyRecordReader.java:238)
  166. ... 21 more
  167. 11:20:34 ERROR org.apache.spark.executor.Executor - Exception in task 4.0 in stage 0.0 (TID 4)
  168. java.lang.RuntimeException: error communicating via Thrift
  169. at org.apache.cassandra.hadoop.ColumnFamilyRecordReader$RowIterator.<init>(ColumnFamilyRecordReader.java:267)
  170. at org.apache.cassandra.hadoop.ColumnFamilyRecordReader$RowIterator.<init>(ColumnFamilyRecordReader.java:215)
  171. at org.apache.cassandra.hadoop.ColumnFamilyRecordReader$StaticRowIterator.<init>(ColumnFamilyRecordReader.java:331)
  172. at org.apache.cassandra.hadoop.ColumnFamilyRecordReader$StaticRowIterator.<init>(ColumnFamilyRecordReader.java:331)
  173. at org.apache.cassandra.hadoop.ColumnFamilyRecordReader.initialize(ColumnFamilyRecordReader.java:171)
  174. at com.thinkaurelius.titan.hadoop.formats.cassandra.CassandraBinaryRecordReader.initialize(CassandraBinaryRecordReader.java:39)
  175. at com.thinkaurelius.titan.hadoop.formats.util.GiraphRecordReader.initialize(GiraphRecordReader.java:38)
  176. at org.apache.spark.rdd.NewHadoopRDD$$anon$1.<init>(NewHadoopRDD.scala:135)
  177. at org.apache.spark.rdd.NewHadoopRDD.compute(NewHadoopRDD.scala:107)
  178. at org.apache.spark.rdd.NewHadoopRDD.compute(NewHadoopRDD.scala:69)
  179. at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:280)
  180. at org.apache.spark.rdd.RDD.iterator(RDD.scala:247)
  181. at org.apache.spark.rdd.MappedRDD.compute(MappedRDD.scala:31)
  182. at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:280)
  183. at org.apache.spark.rdd.RDD.iterator(RDD.scala:247)
  184. at org.apache.spark.scheduler.ShuffleMapTask.runTask(ShuffleMapTask.scala:68)
  185. at org.apache.spark.scheduler.ShuffleMapTask.runTask(ShuffleMapTask.scala:41)
  186. at org.apache.spark.scheduler.Task.run(Task.scala:56)
  187. at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:200)
  188. at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
  189. at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
  190. at java.lang.Thread.run(Thread.java:745)
  191. Caused by: InvalidRequestException(why:unconfigured table schema_columnfamilies)
  192. at org.apache.cassandra.thrift.Cassandra$execute_cql3_query_result$execute_cql3_query_resultStandardScheme.read(Cassandra.java:50297)
  193. at org.apache.cassandra.thrift.Cassandra$execute_cql3_query_result$execute_cql3_query_resultStandardScheme.read(Cassandra.java:50274)
  194. at org.apache.cassandra.thrift.Cassandra$execute_cql3_query_result.read(Cassandra.java:50189)
  195. at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:78)
  196. at org.apache.cassandra.thrift.Cassandra$Client.recv_execute_cql3_query(Cassandra.java:1734)
  197. at org.apache.cassandra.thrift.Cassandra$Client.execute_cql3_query(Cassandra.java:1719)
  198. at org.apache.cassandra.hadoop.ColumnFamilyRecordReader$RowIterator.<init>(ColumnFamilyRecordReader.java:238)
  199. ... 21 more
  200. 11:20:34 ERROR org.apache.spark.scheduler.TaskSchedulerImpl - Exception in statusUpdate
  201. java.util.concurrent.RejectedExecutionException: Task org.apache.spark.scheduler.TaskResultGetter$$anon$3@5f0be712 rejected from java.util.concurrent.ThreadPoolExecutor@1f9803c7[Terminated, pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 4]
  202. at java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolExecutor.java:2047)
  203. at java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:823)
  204. at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1369)
  205. at org.apache.spark.scheduler.TaskResultGetter.enqueueFailedTask(TaskResultGetter.scala:97)
  206. at org.apache.spark.scheduler.TaskSchedulerImpl$$anonfun$liftedTree2$1$1.apply(TaskSchedulerImpl.scala:304)
  207. at org.apache.spark.scheduler.TaskSchedulerImpl$$anonfun$liftedTree2$1$1.apply(TaskSchedulerImpl.scala:298)
  208. at scala.Option.foreach(Option.scala:236)
  209. at org.apache.spark.scheduler.TaskSchedulerImpl.liftedTree2$1(TaskSchedulerImpl.scala:298)
  210. at org.apache.spark.scheduler.TaskSchedulerImpl.statusUpdate(TaskSchedulerImpl.scala:283)
  211. at org.apache.spark.scheduler.local.LocalActor$$anonfun$receiveWithLogging$1.applyOrElse(LocalBackend.scala:61)
  212. at scala.runtime.AbstractPartialFunction$mcVL$sp.apply$mcVL$sp(AbstractPartialFunction.scala:33)
  213. at scala.runtime.AbstractPartialFunction$mcVL$sp.apply(AbstractPartialFunction.scala:33)
  214. at scala.runtime.AbstractPartialFunction$mcVL$sp.apply(AbstractPartialFunction.scala:25)
  215. at org.apache.spark.util.ActorLogReceive$$anon$1.apply(ActorLogReceive.scala:53)
  216. at org.apache.spark.util.ActorLogReceive$$anon$1.apply(ActorLogReceive.scala:42)
  217. at scala.PartialFunction$class.applyOrElse(PartialFunction.scala:118)
  218. at org.apache.spark.util.ActorLogReceive$$anon$1.applyOrElse(ActorLogReceive.scala:42)
  219. at akka.actor.Actor$class.aroundReceive(Actor.scala:465)
  220. at org.apache.spark.scheduler.local.LocalActor.aroundReceive(LocalBackend.scala:43)
  221. at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516)
  222. at akka.actor.ActorCell.invoke(ActorCell.scala:487)
  223. at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:238)
  224. at akka.dispatch.Mailbox.run(Mailbox.scala:220)
  225. at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:393)
  226. at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
  227. at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
  228. at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
  229. at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
  230. [Stage 0:> (0 + 4) / 257]org.apache.spark.SparkException: Job aborted due to stage failure: Task 3 in stage 0.0 failed 1 times, most recent failure: Lost task 3.0 in stage 0.0 (TID 3, localhost): java.lang.RuntimeException: error communicating via Thrift
  231. at org.apache.cassandra.hadoop.ColumnFamilyRecordReader$RowIterator.<init>(ColumnFamilyRecordReader.java:267)
  232. at org.apache.cassandra.hadoop.ColumnFamilyRecordReader$RowIterator.<init>(ColumnFamilyRecordReader.java:215)
  233. at org.apache.cassandra.hadoop.ColumnFamilyRecordReader$StaticRowIterator.<init>(ColumnFamilyRecordReader.java:331)
  234. at org.apache.cassandra.hadoop.ColumnFamilyRecordReader$StaticRowIterator.<init>(ColumnFamilyRecordReader.java:331)
  235. at org.apache.cassandra.hadoop.ColumnFamilyRecordReader.initialize(ColumnFamilyRecordReader.java:171)
  236. at com.thinkaurelius.titan.hadoop.formats.cassandra.CassandraBinaryRecordReader.initialize(CassandraBinaryRecordReader.java:39)
  237. at com.thinkaurelius.titan.hadoop.formats.util.GiraphRecordReader.initialize(GiraphRecordReader.java:38)
  238. at org.apache.spark.rdd.NewHadoopRDD$$anon$1.<init>(NewHadoopRDD.scala:135)
  239. at org.apache.spark.rdd.NewHadoopRDD.compute(NewHadoopRDD.scala:107)
  240. at org.apache.spark.rdd.NewHadoopRDD.compute(NewHadoopRDD.scala:69)
  241. at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:280)
  242. at org.apache.spark.rdd.RDD.iterator(RDD.scala:247)
  243. at org.apache.spark.rdd.MappedRDD.compute(MappedRDD.scala:31)
  244. at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:280)
  245. at org.apache.spark.rdd.RDD.iterator(RDD.scala:247)
  246. at org.apache.spark.scheduler.ShuffleMapTask.runTask(ShuffleMapTask.scala:68)
  247. at org.apache.spark.scheduler.ShuffleMapTask.runTask(ShuffleMapTask.scala:41)
  248. at org.apache.spark.scheduler.Task.run(Task.scala:56)
  249. at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:200)
  250. at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
  251. at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
  252. at java.lang.Thread.run(Thread.java:745)
  253. Caused by: InvalidRequestException(why:unconfigured table schema_columnfamilies)
  254. at org.apache.cassandra.thrift.Cassandra$execute_cql3_query_result$execute_cql3_query_resultStandardScheme.read(Cassandra.java:50297)
  255. at org.apache.cassandra.thrift.Cassandra$execute_cql3_query_result$execute_cql3_query_resultStandardScheme.read(Cassandra.java:50274)
  256. at org.apache.cassandra.thrift.Cassandra$execute_cql3_query_result.read(Cassandra.java:50189)
  257. at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:78)
  258. at org.apache.cassandra.thrift.Cassandra$Client.recv_execute_cql3_query(Cassandra.java:1734)
  259. at org.apache.cassandra.thrift.Cassandra$Client.execute_cql3_query(Cassandra.java:1719)
  260. at org.apache.cassandra.hadoop.ColumnFamilyRecordReader$RowIterator.<init>(ColumnFamilyRecordReader.java:238)
  261. ... 21 more
Add Comment
Please, Sign In to add comment
Public Pastes
We use cookies for various purposes including analytics. By continuing to use Pastebin, you agree to our use of cookies as described in the Cookies Policy.  OK, I Understand
Not a member of Pastebin yet?
Sign Up, it unlocks many cool features!