SparkContext: Created broadcast 8 from
> broadcast at DAGScheduler.scala:839
> 15/05/11 12:50:47 INFO storage.BlockManagerInfo: Removed
> input-0-1431345102800 on dn2.vi:45688 in memory (size: 27.6 KB, free:
> 524.2 MB)
> 15/05/11 12:50:47 ERROR LocalActorRefProvider(akka://sparkDriver):
>
12:50:47 ERROR LocalActorRefProvider(akka://sparkDriver): guardian
failed, shutting down system
java.lang.AssertionError: assertion failed
at scala.Predef$.assert(Predef.scala:165)
at
org.apache.spark.streaming.scheduler.ReceivedBlockTracker.cleanupOldBatches
