diff --git a/streaming/src/test/scala/org/apache/spark/streaming/MasterFailureTest.scala b/streaming/src/test/scala/org/apache/spark/streaming/MasterFailureTest.scala
index 47c5bcf50f660..bd437e4380e25 100644
--- 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