Scala style fixes.

pdeyhim · Apr 16, 2014 · 8533094 · 8533094
1 parent 028bde6
commit 8533094
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 6 deletions.
diff --git a/streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaPairInputDStream.scala b/streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaPairInputDStream.scala
@@ -38,4 +38,4 @@ object JavaPairInputDStream {
        inputDStream: InputDStream[(K, V)]): JavaPairInputDStream[K, V] = {
     new JavaPairInputDStream[K, V](inputDStream)
   }
-}
+}
diff --git a/...ming/src/main/scala/org/apache/spark/streaming/receiver/NetworkReceiverExecutorImpl.scala b/...ming/src/main/scala/org/apache/spark/streaming/receiver/NetworkReceiverExecutorImpl.scala
@@ -144,7 +144,8 @@ private[streaming] class NetworkReceiverExecutorImpl(
 
   /** Report pushed block */
   def reportPushedBlock(blockId: StreamBlockId, numRecords: Long, optionalMetadata: Option[Any]) {
-    trackerActor ! AddBlock(ReceivedBlockInfo(receiverId, blockId, numRecords, optionalMetadata.orNull))
+    val blockInfo = ReceivedBlockInfo(receiverId, blockId, numRecords, optionalMetadata.orNull)
+    trackerActor ! AddBlock(blockInfo)
     logDebug("Reported block " + blockId)
   }
 

diff --git a/streaming/src/test/scala/org/apache/spark/streaming/NetworkReceiverSuite.scala b/streaming/src/test/scala/org/apache/spark/streaming/NetworkReceiverSuite.scala
@@ -21,15 +21,14 @@ import java.nio.ByteBuffer
 
 import scala.collection.mutable.ArrayBuffer
 
+import org.apache.spark.SparkConf
+import org.apache.spark.storage.{StorageLevel, StreamBlockId}
+import org.apache.spark.streaming.receiver.{BlockGenerator, BlockGeneratorListener, NetworkReceiver, NetworkReceiverExecutor}
 import org.scalatest.FunSuite
 import org.scalatest.concurrent.Timeouts
 import org.scalatest.concurrent.Eventually._
 import org.scalatest.time.SpanSugar._
 
-import org.apache.spark.SparkConf
-import org.apache.spark.storage.{StorageLevel, StreamBlockId}
-import org.apache.spark.streaming.receiver.{BlockGenerator, BlockGeneratorListener, NetworkReceiver, NetworkReceiverExecutor}
-import org.apache.spark.streaming.receiver.NetworkReceiverExecutor
 /** Testsuite for testing the network receiver behavior */
 class NetworkReceiverSuite extends FunSuite with Timeouts {