Style.

apache · Jul 24, 2015 · 0f5a5bb · 0f5a5bb
1 parent 2775a64
commit 0f5a5bb
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/streaming/src/test/scala/org/apache/spark/streaming/MasterFailureTest.scala b/streaming/src/test/scala/org/apache/spark/streaming/MasterFailureTest.scala
@@ -156,7 +156,8 @@ object MasterFailureTest extends Logging {
       assert(setupCalled, "Setup was not called in the first call to StreamingContext.getOrCreate")
 
       // Start generating files in the a different thread
-      val fileGeneratingThread = new FileGeneratingThread(input, testDir, batchDuration.milliseconds)
+      val fileGeneratingThread = new FileGeneratingThread(input, testDir,
+        batchDuration.milliseconds)
       fileGeneratingThread.start()
 
       // Run the streams and repeatedly kill it until the last expected output