diff --git a/python/pyspark/serializers.py b/python/pyspark/serializers.py index d8cdcda3a3783a3ed72da1e0492e29dda7154ac6..7f9d0a338d31eba2177656a14227e799218a59be 100644 --- a/python/pyspark/serializers.py +++ b/python/pyspark/serializers.py @@ -272,7 +272,7 @@ class AutoBatchedSerializer(BatchedSerializer): if size < best: batch *= 2 elif size > best * 10 and batch > 1: - batch /= 2 + batch //= 2 def __repr__(self): return "AutoBatchedSerializer(%s)" % self.serializer