Fix syle

tdas · tdas · commit c62e37d65c41 · 2015-08-24T23:07:40.000-07:00
diff --git a/streaming/src/main/scala/org/apache/spark/streaming/dstream/ReceiverInputDStream.scala b/streaming/src/main/scala/org/apache/spark/streaming/dstream/ReceiverInputDStream.scala
@@ -122,7 +122,7 @@ abstract class ReceiverInputDStream[T: ClassTag](@transient ssc_ : StreamingCont
         if (validBlockIds.size != blockIds.size) {
           logWarning("Some blocks could not be recovered as they were not found in memory. " +
             "To prevent such data loss, enabled Write Ahead Log (see programming guide " +
-            "for more details.") 
+            "for more details.")
         }
         new BlockRDD[T](ssc.sc, validBlockIds)
       }

Original file line number	Diff line number	Diff line change
`@@ -122,7 +122,7 @@ abstract class ReceiverInputDStream[T: ClassTag](@transient ssc_ : StreamingCont`
`122`	`122`	`if (validBlockIds.size != blockIds.size) {`
`123`	`123`	`logWarning("Some blocks could not be recovered as they were not found in memory. " +`
`124`	`124`	`"To prevent such data loss, enabled Write Ahead Log (see programming guide " +`
`125`		`- "for more details.")`
	`125`	`+ "for more details.")`
`126`	`126`	`}`
`127`	`127`	`new BlockRDD[T](ssc.sc, validBlockIds)`
`128`	`128`	`}`