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:33:42 -0700 |
| commit | aa8bb117a3ff98420ab751ba4ddbaad88ab57f9d (patch) | |
| tree | def96664478052ca08a00903caf59cd02fe971d1 /streaming | |
| parent | fdfb45e691946f3153d6c696bec6d7f3e391e301 (diff) | |
| download | spark-aa8bb117a3ff98420ab751ba4ddbaad88ab57f9d.tar.gz spark-aa8bb117a3ff98420ab751ba4ddbaad88ab57f9d.tar.bz2 spark-aa8bb117a3ff98420ab751ba4ddbaad88ab57f9d.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
Diffstat (limited to 'streaming')
| -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 + ")") } |