Style fix.

tdas · tdas · commit dbddf75eb9c3 · 2014-04-24T18:25:02.000-07:00
diff --git a/streaming/src/main/scala/org/apache/spark/streaming/scheduler/ReceiverTracker.scala b/streaming/src/main/scala/org/apache/spark/streaming/scheduler/ReceiverTracker.scala
@@ -124,7 +124,8 @@ class ReceiverTracker(ssc: StreamingContext) extends Logging {
     if (!receiverInputStreamMap.contains(streamId)) {
       throw new Exception("Register received for unexpected id " + streamId)
     }
-    receiverInfo(streamId) = ReceiverInfo(streamId, s"${typ}-${streamId}", receiverActor, true, host)
+    receiverInfo(streamId) = ReceiverInfo(
+      streamId, s"${typ}-${streamId}", receiverActor, true, host)
     ssc.scheduler.listenerBus.post(StreamingListenerReceiverStarted(receiverInfo(streamId)))
     logInfo("Registered receiver for stream " + streamId + " from " + sender.path.address)
   }

Original file line number	Diff line number	Diff line change
`@@ -124,7 +124,8 @@ class ReceiverTracker(ssc: StreamingContext) extends Logging {`
`124`	`124`	`if (!receiverInputStreamMap.contains(streamId)) {`
`125`	`125`	`throw new Exception("Register received for unexpected id " + streamId)`
`126`	`126`	`}`
`127`		`- receiverInfo(streamId) = ReceiverInfo(streamId, s"${typ}-${streamId}", receiverActor, true, host)`
	`127`	`+ receiverInfo(streamId) = ReceiverInfo(`
	`128`	`+ streamId, s"${typ}-${streamId}", receiverActor, true, host)`
`128`	`129`	`ssc.scheduler.listenerBus.post(StreamingListenerReceiverStarted(receiverInfo(streamId)))`
`129`	`130`	`logInfo("Registered receiver for stream " + streamId + " from " + sender.path.address)`
`130`	`131`	`}`