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 apache#390 from baishuo/windowdstream and squashes the following commits:

533c968 [baishuo(白硕)] Update WindowedDStream.scala
  • Loading branch information
baishuo authored and pwendell committed Apr 12, 2014
1 parent fdfb45e commit aa8bb11
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 aa8bb11

Please sign in to comment.