diff --git a/python/pyspark/streaming/pyprint.py b/python/pyspark/streaming/pyprint.py index fcdaca510812c..6e87c985a57e3 100644 --- a/python/pyspark/streaming/pyprint.py +++ b/python/pyspark/streaming/pyprint.py @@ -1,6 +1,6 @@ import sys from itertools import chain -from pyspark.serializers import PickleSerializer, BatchedSerializer, UTF8Deserializer +from pyspark.serializers import PickleSerializer def collect(binary_file_path): dse = PickleSerializer() diff --git a/streaming/pom.xml b/streaming/pom.xml index 88df63592efee..2239ad9c8579c 100644 --- a/streaming/pom.xml +++ b/streaming/pom.xml @@ -21,7 +21,7 @@ org.apache.spark spark-parent - 1.0.0 + 1.1.0-SNAPSHOT ../pom.xml