diff options
| -rw-r--r-- | python/pyspark/serializers.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/python/pyspark/serializers.py b/python/pyspark/serializers.py index d8cdcda3a3..7f9d0a338d 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 |