You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by pw...@apache.org on 2014/04/13 23:32:44 UTC
git commit: Small syntax error from previous backport
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 <pw...@gmail.com>
Authored: Sun Apr 13 14:32:22 2014 -0700
Committer: Patrick Wendell <pw...@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 + ")")