HyukjinKwon commented on a change in pull request #23117:
[WIP][SPARK-7721][INFRA] Run and generate test coverage report from Python via
Jenkins
URL: https://github.com/apache/spark/pull/23117#discussion_r252108476
##########
File path: python/pyspark/rdd.py
##########
@@ -2509,7 +2509,7 @@ def pipeline_func(split, iterator):
self._jrdd_deserializer = self.ctx.serializer
self._bypass_serializer = False
self.partitioner = prev.partitioner if self.preservesPartitioning else
None
- self.is_barrier = prev._is_barrier() or isFromBarrier
+ self.is_barrier = isFromBarrier or prev._is_barrier()
Review comment:
I made this change into a separate PR -
https://github.com/apache/spark/pull/23690
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
With regards,
Apache Git Services
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
