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/12 05:34:03 UTC
git commit: Update WindowedDStream.scala
Repository: spark
Updated Branches:
refs/heads/master fdfb45e69 -> aa8bb117a
Update WindowedDStream.scala
update the content of Exception when windowDuration is not multiple of parent.slideDuration
Author: baishuo(白硕) <vc...@hotmail.com>
Closes #390 from baishuo/windowdstream and squashes the following commits:
533c968 [baishuo(白硕)] Update WindowedDStream.scala
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/aa8bb117
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/aa8bb117
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/aa8bb117
Branch: refs/heads/master
Commit: aa8bb117a3ff98420ab751ba4ddbaad88ab57f9d
Parents: fdfb45e
Author: baishuo(白硕) <vc...@hotmail.com>
Authored: Fri Apr 11 20:33:42 2014 -0700
Committer: Patrick Wendell <pw...@gmail.com>
Committed: Fri Apr 11 20:33:42 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/aa8bb117/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 24289b7..775b6bf 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 + ")")
}