use protocol 2 in CloudPickle

davies · davies · commit 9aed6c5c0a59 · 2014-09-11T10:13:07.000-07:00
diff --git a/python/pyspark/serializers.py b/python/pyspark/serializers.py
@@ -362,7 +362,7 @@ def loads(self, obj):
 class CloudPickleSerializer(PickleSerializer):
 
     def dumps(self, obj):
-        return cloudpickle.dumps(obj)
+        return cloudpickle.dumps(obj, 2)
 
 
 class MarshalSerializer(FramedSerializer):
