Repository: spark Updated Branches: refs/heads/branch-1.0 51c41da51 -> 822353dc5
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 07b7ad30808ea73a375be8a86e96199d704d1422) Signed-off-by: Reynold Xin <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/spark/repo Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/822353dc Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/822353dc Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/822353dc Branch: refs/heads/branch-1.0 Commit: 822353dc59ce6eb410e9f17f78be24afaa199679 Parents: 51c41da Author: baishuo(ç½ç¡) <[email protected]> Authored: Wed Apr 16 18:08:11 2014 -0700 Committer: Reynold Xin <[email protected]> Committed: Wed Apr 16 18:08:24 2014 -0700 ---------------------------------------------------------------------- .../apache/spark/streaming/dstream/ReducedWindowedDStream.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/spark/blob/822353dc/streaming/src/main/scala/org/apache/spark/streaming/dstream/ReducedWindowedDStream.scala ---------------------------------------------------------------------- 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 b334d68..40da313 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 + ")" )
