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 pdeyhim committed Jun 25, 2014
1 parent b86c234 commit a1e60fd
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 a1e60fd

Please sign in to comment.