refactor

YanTangZhai · Sep 30, 2014 · fa7261b · fa7261b
1 parent a13ff34
commit fa7261b
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/streaming/src/main/scala/org/apache/spark/streaming/api/python/PythonDStream.scala b/streaming/src/main/scala/org/apache/spark/streaming/api/python/PythonDStream.scala
@@ -239,7 +239,10 @@ class PythonReducedWindowedDStream(parent: DStream[Array[Byte]],
                                    @transient pinvReduceFunc: PythonRDDFunction,
                                    _windowDuration: Duration,
                                    _slideDuration: Duration
-                                   ) extends PythonStateDStream(parent, preduceFunc) {
+                                   ) extends PythonDStream(parent, preduceFunc) {
+
+  super.persist(StorageLevel.MEMORY_ONLY)
+  override val mustCheckpoint = true
 
   val invReduceFunc = new RDDFunction(pinvReduceFunc)