Small syntax error from previous backport

aarondav · Apr 13, 2014 · 9e89789 · 9e89789
1 parent 4a325e1
commit 9e89789
Showing 1 changed file with 1 addition and 1 deletion.
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
@@ -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 + ")")