Fixed long line.

pdeyhim · Apr 10, 2014 · fa760fe · fa760fe
1 parent 1c0bcef
commit fa760fe
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/streaming/src/main/scala/org/apache/spark/streaming/scheduler/NetworkInputTracker.scala b/streaming/src/main/scala/org/apache/spark/streaming/scheduler/NetworkInputTracker.scala
@@ -118,7 +118,13 @@ class NetworkInputTracker(ssc: StreamingContext) extends Logging {
   }
 
   /** Register a receiver */
-  def registerReceiver(streamId: Int, typ: String, host: String, receiverActor: ActorRef, sender: ActorRef) {
+  def registerReceiver(
+      streamId: Int,
+      typ: String,
+      host: String,
+      receiverActor: ActorRef,
+      sender: ActorRef
+    ) {
     if (!networkInputStreamMap.contains(streamId)) {
       throw new Exception("Register received for unexpected id " + streamId)
     }