We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 1fa48d9 commit 533c968Copy full SHA for 533c968
streaming/src/main/scala/org/apache/spark/streaming/dstream/WindowedDStream.scala
@@ -32,7 +32,7 @@ class WindowedDStream[T: ClassTag](
32
extends DStream[T](parent.ssc) {
33
34
if (!_windowDuration.isMultipleOf(parent.slideDuration)) {
35
- throw new Exception("The window duration of windowed DStream (" + _slideDuration + ") " +
+ throw new Exception("The window duration of windowed DStream (" + _windowDuration + ") " +
36
"must be a multiple of the slide duration of parent DStream (" + parent.slideDuration + ")")
37
}
38
0 commit comments