Skip to content

Commit

Permalink
Update WindowedDStream.scala
Browse files Browse the repository at this point in the history
update the content of Exception when windowDuration is not multiple of parent.slideDuration

Author: baishuo(白硕) <vc_java@hotmail.com>

Closes #390 from baishuo/windowdstream and squashes the following commits:

533c968 [baishuo(白硕)] Update WindowedDStream.scala
(cherry picked from commit aa8bb11)

Signed-off-by: Patrick Wendell <pwendell@gmail.com>
  • Loading branch information
baishuo authored and pwendell committed Apr 12, 2014
1 parent ce0ce3d commit dac6240
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,7 @@ class WindowedDStream[T: ClassTag](
extends DStream[T](parent.ssc) {

if (!_windowDuration.isMultipleOf(parent.slideDuration)) {
throw new Exception("The window duration of windowed DStream (" + _slideDuration + ") " +
throw new Exception("The window duration of windowed DStream (" + _windowDuration + ") " +
"must be a multiple of the slide duration of parent DStream (" + parent.slideDuration + ")")
}

Expand Down

0 comments on commit dac6240

Please sign in to comment.