From fedad01d45937a75842e2ab18f496d56167bf3d1 Mon Sep 17 00:00:00 2001 From: Sasi Kanth Lanka Date: Fri, 25 Jul 2014 17:54:29 +0530 Subject: [PATCH] Remove console logging in ActorReceiver.scala For large scale stream processing the console logging is hindering throughput. --- .../apache/spark/streaming/receiver/ActorReceiver.scala | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/streaming/src/main/scala/org/apache/spark/streaming/receiver/ActorReceiver.scala b/streaming/src/main/scala/org/apache/spark/streaming/receiver/ActorReceiver.scala index 743be58950c09..217bbb5b4a701 100644 --- a/streaming/src/main/scala/org/apache/spark/streaming/receiver/ActorReceiver.scala +++ b/streaming/src/main/scala/org/apache/spark/streaming/receiver/ActorReceiver.scala @@ -74,7 +74,7 @@ trait ActorHelper { /** Store an iterator of received data as a data block into Spark's memory. */ def store[T](iter: Iterator[T]) { - println("Storing iterator") + //println("Storing iterator") context.parent ! IteratorData(iter) } @@ -93,7 +93,7 @@ trait ActorHelper { * being pushed into Spark's memory. */ def store[T](item: T) { - println("Storing item") + //println("Storing item") context.parent ! SingleItemData(item) } } @@ -157,11 +157,11 @@ private[streaming] class ActorReceiver[T: ClassTag]( def receive = { case IteratorData(iterator) => - println("received iterator") + //println("received iterator") store(iterator.asInstanceOf[Iterator[T]]) case SingleItemData(msg) => - println("received single") + //println("received single") store(msg.asInstanceOf[T]) n.incrementAndGet