Github user viirya commented on a diff in the pull request:
https://github.com/apache/spark/pull/22085#discussion_r209464569
--- Diff: python/pyspark/worker.py ---
@@ -261,6 +263,9 @@ def main(infile, outfile):
# initialize global state
taskContext = TaskContext._getOrCreate()
+ isBarrier = read_bool(infile)
--- End diff --
Add a comment indicating the following 3 inputs are only for barrier task?
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
