Skip to content

Commit 07b7ad3

Browse files
baishuorxin
authored andcommitted
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
1 parent 9c40b9e commit 07b7ad3

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

streaming/src/main/scala/org/apache/spark/streaming/dstream/ReducedWindowedDStream.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -43,7 +43,7 @@ class ReducedWindowedDStream[K: ClassTag, V: ClassTag](
4343
) extends DStream[(K,V)](parent.ssc) {
4444

4545
assert(_windowDuration.isMultipleOf(parent.slideDuration),
46-
"The window duration of ReducedWindowedDStream (" + _slideDuration + ") " +
46+
"The window duration of ReducedWindowedDStream (" + _windowDuration + ") " +
4747
"must be multiple of the slide duration of parent DStream (" + parent.slideDuration + ")"
4848
)
4949

0 commit comments

Comments
 (0)