diff options
| author | baishuo(白硕) <vc_java@hotmail.com> | 2014-04-16 18:08:11 -0700 |
|---|---|---|
| committer | Reynold Xin <rxin@apache.org> | 2014-04-16 18:08:24 -0700 |
| commit | 822353dc59ce6eb410e9f17f78be24afaa199679 (patch) | |
| tree | f40bf8e638c5a08c0ecee44f12ab525c4a291c45 /streaming/src/main/scala | |
| parent | 51c41da51681ca6f58cc62813744851ddcbda28a (diff) | |
| download | spark-822353dc59ce6eb410e9f17f78be24afaa199679.tar.gz spark-822353dc59ce6eb410e9f17f78be24afaa199679.tar.bz2 spark-822353dc59ce6eb410e9f17f78be24afaa199679.zip | |
Update ReducedWindowedDStream.scala
change _slideDuration to _windowDuration
Author: baishuo(白硕) <vc_java@hotmail.com>
Closes #425 from baishuo/master and squashes the following commits:
6f09ea1 [baishuo(白硕)] Update ReducedWindowedDStream.scala
(cherry picked from commit 07b7ad30808ea73a375be8a86e96199d704d1422)
Signed-off-by: Reynold Xin <rxin@apache.org>
Diffstat (limited to 'streaming/src/main/scala')
| -rw-r--r-- | streaming/src/main/scala/org/apache/spark/streaming/dstream/ReducedWindowedDStream.scala | 2 |
1 files changed, 1 insertions, 1 deletions
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 b334d68bf9..40da313189 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 + ")" ) |