Update ReducedWindowedDStream.scala

pdeyhim · Apr 16, 2014 · 6f09ea1 · 6f09ea1
1 parent 1fa48d9
commit 6f09ea1
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 + ")"
   )