@@ -37,7 +37,7 @@ class SparkSinkSuite extends TestSuiteBase {
3737 val eventsPerBatch = 1000
3838 val channelCapacity = 5000
3939
40- test(" Success test " ) {
40+ test(" Success" ) {
4141 val (channel, sink) = initializeChannelAndSink(None )
4242 channel.start()
4343 sink.start()
@@ -150,8 +150,8 @@ class SparkSinkSuite extends TestSuiteBase {
150150 transAndClient.foreach(x => x._1.close())
151151 }
152152
153- def initializeChannelAndSink (overrides : Option [Map [String , String ]]):
154- ( MemoryChannel , SparkSink ) = {
153+ def initializeChannelAndSink (overrides : Option [Map [String , String ]]): ( MemoryChannel ,
154+ SparkSink ) = {
155155 val channel = new MemoryChannel ()
156156 val channelContext = new Context ()
157157
@@ -178,8 +178,8 @@ class SparkSinkSuite extends TestSuiteBase {
178178 tx.close()
179179 }
180180
181- private def getTransceiverAndClient (address : InetSocketAddress , count : Int ) :
182- Seq [(NettyTransceiver , SparkFlumeProtocol .Callback )] = {
181+ private def getTransceiverAndClient (address : InetSocketAddress ,
182+ count : Int ) : Seq [(NettyTransceiver , SparkFlumeProtocol .Callback )] = {
183183
184184 (1 to count).map(_ => {
185185 lazy val channelFactoryExecutor =
@@ -203,5 +203,4 @@ class SparkSinkSuite extends TestSuiteBase {
203203 val m = queueRemaining.get(channel).getClass.getDeclaredMethod(" availablePermits" )
204204 m.invoke(queueRemaining.get(channel)).asInstanceOf [Int ]
205205 }
206-
207206}
0 commit comments