Github user cclauss commented on a diff in the pull request:
https://github.com/apache/spark/pull/20838#discussion_r181192109
--- Diff: python/pyspark/cloudpickle.py ---
@@ -802,9 +802,8 @@ def save_not_implemented(self, obj):
self.save_reduce(_gen_not_implemented, ())
if PY3:
- dispatch[io.TextIOWrapper] = save_file
- else:
- dispatch[file] = save_file
+ file = io.TextIOWrapper
+ dispatch[file] = save_file
--- End diff --
This was merged upstream.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
