diff --git a/python/pyspark/worker.py b/python/pyspark/worker.py index 386efadce58e..abd03fffdf68 100644 --- a/python/pyspark/worker.py +++ b/python/pyspark/worker.py @@ -3493,7 +3493,6 @@ def main(infile, outfile): shuffle.MemoryBytesSpilled = 0 shuffle.DiskBytesSpilled = 0 - _accumulatorRegistry.clear() setup_spark_files(infile) setup_broadcasts(infile)