From c9190d11b4644c1588ff63264bf588f7a243147f Mon Sep 17 00:00:00 2001 From: Hari Shreedharan Date: Mon, 18 Aug 2014 15:07:25 -0700 Subject: [PATCH] Indentation and spaces changes --- .../spark/streaming/flume/sink/SparkSinkSuite.scala | 11 +++++------ 1 file changed, 5 insertions(+), 6 deletions(-) diff --git a/external/flume-sink/src/test/scala/org/apache/spark/streaming/flume/sink/SparkSinkSuite.scala b/external/flume-sink/src/test/scala/org/apache/spark/streaming/flume/sink/SparkSinkSuite.scala index d0c0a2b781130..adcfd169a59df 100644 --- a/external/flume-sink/src/test/scala/org/apache/spark/streaming/flume/sink/SparkSinkSuite.scala +++ b/external/flume-sink/src/test/scala/org/apache/spark/streaming/flume/sink/SparkSinkSuite.scala @@ -37,7 +37,7 @@ class SparkSinkSuite extends TestSuiteBase { val eventsPerBatch = 1000 val channelCapacity = 5000 - test("Success test") { + test("Success") { val (channel, sink) = initializeChannelAndSink(None) channel.start() sink.start() @@ -150,8 +150,8 @@ class SparkSinkSuite extends TestSuiteBase { transAndClient.foreach(x => x._1.close()) } - def initializeChannelAndSink(overrides: Option[Map[String, String]]): - (MemoryChannel, SparkSink) = { + def initializeChannelAndSink(overrides: Option[Map[String, String]]): (MemoryChannel, + SparkSink) = { val channel = new MemoryChannel() val channelContext = new Context() @@ -178,8 +178,8 @@ class SparkSinkSuite extends TestSuiteBase { tx.close() } - private def getTransceiverAndClient(address: InetSocketAddress, count: Int): - Seq[(NettyTransceiver, SparkFlumeProtocol.Callback)] = { + private def getTransceiverAndClient(address: InetSocketAddress, + count: Int): Seq[(NettyTransceiver, SparkFlumeProtocol.Callback)] = { (1 to count).map(_ => { lazy val channelFactoryExecutor = @@ -203,5 +203,4 @@ class SparkSinkSuite extends TestSuiteBase { val m = queueRemaining.get(channel).getClass.getDeclaredMethod("availablePermits") m.invoke(queueRemaining.get(channel)).asInstanceOf[Int] } - }