Created
December 11, 2014 11:21
-
-
Save akhld/b5627bf866721df7321b to your computer and use it in GitHub Desktop.
Standalone stacktrace
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
[error] (Thread-37) org.apache.spark.SparkException: Job aborted due to stage failure: All masters are unresponsive! Giving up. | |
org.apache.spark.SparkException: Job aborted due to stage failure: All masters are unresponsive! Giving up. | |
at org.apache.spark.scheduler.DAGScheduler.org$apache$spark$scheduler$DAGScheduler$$failJobAndIndependentStages(DAGScheduler.scala:1044) | |
at org.apache.spark.scheduler.DAGScheduler$$anonfun$abortStage$1.apply(DAGScheduler.scala:1028) | |
at org.apache.spark.scheduler.DAGScheduler$$anonfun$abortStage$1.apply(DAGScheduler.scala:1026) | |
at scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:59) | |
at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:47) | |
at org.apache.spark.scheduler.DAGScheduler.abortStage(DAGScheduler.scala:1026) | |
at org.apache.spark.scheduler.DAGScheduler$$anonfun$handleTaskSetFailed$1.apply(DAGScheduler.scala:634) | |
at org.apache.spark.scheduler.DAGScheduler$$anonfun$handleTaskSetFailed$1.apply(DAGScheduler.scala:634) | |
at scala.Option.foreach(Option.scala:236) | |
at org.apache.spark.scheduler.DAGScheduler.handleTaskSetFailed(DAGScheduler.scala:634) | |
at org.apache.spark.scheduler.DAGSchedulerEventProcessActor$$anonfun$receive$2.applyOrElse(DAGScheduler.scala:1229) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:498) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:456) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:237) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:219) | |
at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:386) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
[trace] Stack trace suppressed: run last compile:run for the full output. | |
------------------------------------------- | |
Time: 1418296114000 ms | |
------------------------------------------- | |
[error] (run-main-0) org.apache.spark.SparkException: SparkContext has been shutdown | |
org.apache.spark.SparkException: SparkContext has been shutdown | |
at org.apache.spark.SparkContext.runJob(SparkContext.scala:1045) | |
at org.apache.spark.SparkContext.runJob(SparkContext.scala:1069) | |
at org.apache.spark.SparkContext.runJob(SparkContext.scala:1083) | |
at org.apache.spark.SparkContext.runJob(SparkContext.scala:1097) | |
at org.apache.spark.rdd.RDD.count(RDD.scala:847) | |
at LowLevelKafkaConsumer$$anonfun$main$2.apply(LowLevelKafkaConsumer.scala:60) | |
at LowLevelKafkaConsumer$$anonfun$main$2.apply(LowLevelKafkaConsumer.scala:60) | |
at org.apache.spark.streaming.dstream.DStream$$anonfun$foreachRDD$1.apply(DStream.scala:527) | |
at org.apache.spark.streaming.dstream.DStream$$anonfun$foreachRDD$1.apply(DStream.scala:527) | |
at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1.apply$mcV$sp(ForEachDStream.scala:41) | |
at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1.apply(ForEachDStream.scala:40) | |
at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1.apply(ForEachDStream.scala:40) | |
at scala.util.Try$.apply(Try.scala:161) | |
at org.apache.spark.streaming.scheduler.Job.run(Job.scala:32) | |
at org.apache.spark.streaming.scheduler.JobScheduler$JobHandler.run(JobScheduler.scala:172) | |
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:745) | |
[trace] Stack trace suppressed: run last compile:run for the full output. | |
INFO : Remoting - Remoting shut down |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment