Update ReducedWindowedDStream.scala

change _slideDuration to _windowDuration Author: baishuo(白硕) <[email protected]> Closes #425 from baishuo/master and squashes the following commits: 6f09ea1 [baishuo(白硕)] Update ReducedWindowedDStream.scala (cherry picked from commit 07b7ad3) Signed-off-by: Reynold Xin <[email protected]>
apache · Apr 17, 2014 · 822353d · 822353d
1 parent 51c41da
commit 822353d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/streaming/src/main/scala/org/apache/spark/streaming/dstream/ReducedWindowedDStream.scala b/streaming/src/main/scala/org/apache/spark/streaming/dstream/ReducedWindowedDStream.scala
@@ -43,7 +43,7 @@ class ReducedWindowedDStream[K: ClassTag, V: ClassTag](
   ) extends DStream[(K,V)](parent.ssc) {
 
   assert(_windowDuration.isMultipleOf(parent.slideDuration),
-    "The window duration of ReducedWindowedDStream (" + _slideDuration + ") " +
+    "The window duration of ReducedWindowedDStream (" + _windowDuration + ") " +
       "must be multiple of the slide duration of parent DStream (" + parent.slideDuration + ")"
   )