Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- 18/05/30 11:38:25 WARN TaskSetManager: Lost task 0.0 in stage 5774.0 (TID 9966, 172.20.2.177, executor 1): java.lang.AbstractMethodError: org.apache.spark.streaming.amqp.ReliableAMQPReceiver.initializeLogIfNecessary(ZZ)Z
- at org.apache.spark.internal.Logging$class.initializeLogIfNecessary(Logging.scala:99)
- at org.apache.spark.streaming.amqp.AMQPReceiver.initializeLogIfNecessary(AMQPReceiver.scala:37)
- at org.apache.spark.internal.Logging$class.log(Logging.scala:46)
- at org.apache.spark.streaming.amqp.AMQPReceiver.log(AMQPReceiver.scala:37)
- at org.apache.spark.internal.Logging$class.logInfo(Logging.scala:54)
- at org.apache.spark.streaming.amqp.AMQPReceiver.logInfo(AMQPReceiver.scala:37)
- at org.apache.spark.streaming.amqp.AMQPReceiver.onStart(AMQPReceiver.scala:56)
- at org.apache.spark.streaming.amqp.ReliableAMQPReceiver.onStart(ReliableAMQPReceiver.scala:68)
- at org.apache.spark.streaming.receiver.ReceiverSupervisor.startReceiver(ReceiverSupervisor.scala:149)
- at org.apache.spark.streaming.receiver.ReceiverSupervisor.start(ReceiverSupervisor.scala:131)
- at org.apache.spark.streaming.scheduler.ReceiverTracker$ReceiverTrackerEndpoint$$anonfun$9.apply(ReceiverTracker.scala:600)
- at org.apache.spark.streaming.scheduler.ReceiverTracker$ReceiverTrackerEndpoint$$anonfun$9.apply(ReceiverTracker.scala:590)
- at org.apache.spark.SparkContext$$anonfun$34.apply(SparkContext.scala:2178)
- at org.apache.spark.SparkContext$$anonfun$34.apply(SparkContext.scala:2178)
- at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:87)
- at org.apache.spark.scheduler.Task.run(Task.scala:109)
- at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:345)
- at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
- at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
- at java.lang.Thread.run(Thread.java:748)
Advertisement
Add Comment
Please, Sign In to add comment