From 6f09ea1e6c2892a6f04a197931d4385a8c3cee2d Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?baishuo=28=E7=99=BD=E7=A1=95=29?= Date: Wed, 16 Apr 2014 17:42:09 +0800 Subject: [PATCH] Update ReducedWindowedDStream.scala --- .../apache/spark/streaming/dstream/ReducedWindowedDStream.scala | 2 +- 1 file changed, 1 insertion(+), 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 index ca0a8ae47864d..f7679f61c409a 100644 --- 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 + ")" )