refactor

rxin · Oct 1, 2014 · 7797c70 · 7797c70
1 parent ff88bec
commit 7797c70
Showing 1 changed file with 1 addition 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
@@ -174,7 +174,7 @@ class PythonTransformedDStream (parent: DStream[_], @transient pfunc: PythonTran
         // try to use the result as a template
         r.get match {
           case pyrdd: PythonRDD =>
-            if (pyrdd.parent(0) == rdd) {
+            if (pyrdd.firstParent == rdd) {
               // only one PythonRDD
               lastResult = pyrdd
             } else {