Details
Description
Callback functions for spark transformations and actions will be pickled.
If the callback is instancemethod of _main_ module's class, and the class has more than one instancemethod which using class properties or classmethods, the class will be pickled twice, and 'pickle.memoize' twice, then trigger AssertionError.
Demo code and traceback attached.
Attachments
Attachments
Issue Links
- is duplicated by
-
SPARK-13697 TransformFunctionSerializer.loads doesn't restore the function's module name if it's '__main__'
- Resolved