diff options
| author | baishuo(白硕) <vc_java@hotmail.com> | 2014-04-11 20:33:42 -0700 |
|---|---|---|
| committer | Patrick Wendell <pwendell@gmail.com> | 2014-04-11 20:34:09 -0700 |
| commit | dac6240cf3e5a007f27d6e765198263f993ff040 (patch) | |
| tree | def96664478052ca08a00903caf59cd02fe971d1 /streaming/src/main/scala/org | |
| parent | ce0ce3d9e1ebb6a25bfc27ef3c6becff5a5acf91 (diff) | |
| download | spark-dac6240cf3e5a007f27d6e765198263f993ff040.tar.gz spark-dac6240cf3e5a007f27d6e765198263f993ff040.tar.bz2 spark-dac6240cf3e5a007f27d6e765198263f993ff040.zip | |
Update WindowedDStream.scala
update the content of Exception when windowDuration is not multiple of parent.slideDuration
Author: baishuo(白硕) <vc_java@hotmail.com>
Closes #390 from baishuo/windowdstream and squashes the following commits:
533c968 [baishuo(白硕)] Update WindowedDStream.scala
(cherry picked from commit aa8bb117a3ff98420ab751ba4ddbaad88ab57f9d)
Signed-off-by: Patrick Wendell <pwendell@gmail.com>
Diffstat (limited to 'streaming/src/main/scala/org')
| -rw-r--r-- | streaming/src/main/scala/org/apache/spark/streaming/dstream/WindowedDStream.scala | 2 |
1 files changed, 1 insertions, 1 deletions
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 24289b714f..775b6bfd06 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 @@ -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 + ")") } |