From fa760fe0e9c30a6f65035bc341cf110ab5020138 Mon Sep 17 00:00:00 2001 From: Tathagata Das Date: Wed, 9 Apr 2014 22:53:04 -0700 Subject: [PATCH] Fixed long line. --- .../spark/streaming/scheduler/NetworkInputTracker.scala | 8 +++++++- 1 file changed, 7 insertions(+), 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 index 4fe4a10163c31..a1e6f5176825a 100644 --- 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) }