Repository: spark Updated Branches: refs/heads/branch-0.9 4a325e17b -> 9e8978903
Small syntax error from previous backport Project: http://git-wip-us.apache.org/repos/asf/spark/repo Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/9e897890 Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/9e897890 Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/9e897890 Branch: refs/heads/branch-0.9 Commit: 9e897890351f1654c5b31f8d4688779f8140857c Parents: 4a325e1 Author: Patrick Wendell <pwend...@gmail.com> Authored: Sun Apr 13 14:32:22 2014 -0700 Committer: Patrick Wendell <pwend...@gmail.com> Committed: Sun Apr 13 14:32:22 2014 -0700 ---------------------------------------------------------------------- .../scala/org/apache/spark/streaming/dstream/WindowedDStream.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/spark/blob/9e897890/streaming/src/main/scala/org/apache/spark/streaming/dstream/WindowedDStream.scala ---------------------------------------------------------------------- diff --git a/streaming/src/main/scala/org/apache/spark/streaming/dstream/WindowedDStream.scala b/streaming/src/main/scala/org/apache/spark/streaming/dstream/WindowedDStream.scala index 87df0c2..d3f51f0 100644 --- a/streaming/src/main/scala/org/apache/spark/streaming/dstream/WindowedDStream.scala +++ b/streaming/src/main/scala/org/apache/spark/streaming/dstream/WindowedDStream.scala @@ -31,7 +31,7 @@ class WindowedDStream[T: ClassTag]( _slideDuration: Duration) extends DStream[T](parent.ssc) { - if (!_windowDuration.isMultipleOf(parent.slideDuration)) { + if (!_windowDuration.isMultipleOf(parent.slideDuration)) throw new Exception("The window duration of windowed DStream (" + _windowDuration + ") " + "must be a multiple of the slide duration of parent DStream (" + parent.slideDuration + ")")