Skip to content

Commit 7797c70

Browse files
committed
refactor
1 parent ff88bec commit 7797c70

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

streaming/src/main/scala/org/apache/spark/streaming/api/python/PythonDStream.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -174,7 +174,7 @@ class PythonTransformedDStream (parent: DStream[_], @transient pfunc: PythonTran
174174
// try to use the result as a template
175175
r.get match {
176176
case pyrdd: PythonRDD =>
177-
if (pyrdd.parent(0) == rdd) {
177+
if (pyrdd.firstParent == rdd) {
178178
// only one PythonRDD
179179
lastResult = pyrdd
180180
} else {

0 commit comments

Comments
 (0)