diff --git a/python/pyspark/serializers.py b/python/pyspark/serializers.py
index 9338df69ff60ac7eba26bbd177c00109c4f72f80..811fa6f018b23f3c9883bd2a770f03c044786850 100644
--- a/python/pyspark/serializers.py
+++ b/python/pyspark/serializers.py
@@ -179,8 +179,6 @@ class BatchedSerializer(Serializer):
                 yield items
 
     def dump_stream(self, iterator, stream):
-        if isinstance(iterator, basestring):
-            iterator = [iterator]
         self.serializer.dump_stream(self._batched(iterator), stream)
 
     def load_stream(self, stream):