Fixed long line.

tdas · tdas · commit fa760fe0e9c3 · 2014-04-09T22:53:04.000-07:00
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)
     }

Original file line number	Diff line number	Diff line change
`@@ -118,7 +118,13 @@ class NetworkInputTracker(ssc: StreamingContext) extends Logging {`
`118`	`118`	`}`
`119`	`119`
`120`	`120`	`/** Register a receiver */`
`121`		`- def registerReceiver(streamId: Int, typ: String, host: String, receiverActor: ActorRef, sender: ActorRef) {`
	`121`	`+ def registerReceiver(`
	`122`	`+ streamId: Int,`
	`123`	`+ typ: String,`
	`124`	`+ host: String,`
	`125`	`+ receiverActor: ActorRef,`
	`126`	`+ sender: ActorRef`
	`127`	`+ ) {`
`122`	`128`	`if (!networkInputStreamMap.contains(streamId)) {`
`123`	`129`	`throw new Exception("Register received for unexpected id " + streamId)`
`124`	`130`	`}`