From cf1c55e4fe891742bd2102606b901cc834a87557 Mon Sep 17 00:00:00 2001 From: Davies Liu Date: Tue, 9 Sep 2014 17:54:35 -0700 Subject: [PATCH] address comments --- python/pyspark/worker.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/python/pyspark/worker.py b/python/pyspark/worker.py index 9acad54eb7e42..61b8a74d060e8 100644 --- a/python/pyspark/worker.py +++ b/python/pyspark/worker.py @@ -74,7 +74,7 @@ def main(infile, outfile): _broadcastRegistry[bid] = Broadcast(bid, value) else: bid = - bid - 1 - _broadcastRegistry.pop(bid, None) + _broadcastRegistry.remove(bid) _accumulatorRegistry.clear() command = pickleSer._read_with_length(infile)