From 23b039a896497c8f4cae1bf963274ff295841c37 Mon Sep 17 00:00:00 2001 From: Davies Liu Date: Tue, 27 Jan 2015 22:56:42 -0800 Subject: [PATCH] address comments --- examples/src/main/python/streaming/kafka_wordcount.py | 2 +- python/pyspark/serializers.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/examples/src/main/python/streaming/kafka_wordcount.py b/examples/src/main/python/streaming/kafka_wordcount.py index 58201f967664a..ed398a82b8bb0 100644 --- a/examples/src/main/python/streaming/kafka_wordcount.py +++ b/examples/src/main/python/streaming/kafka_wordcount.py @@ -21,7 +21,7 @@ To run this on your local machine, you need to setup Kafka and create a producer first, see http://kafka.apache.org/documentation.html#quickstart - + and then run the example `$ bin/spark-submit --driver-class-path external/kafka-assembly/target/scala-*/\ spark-streaming-kafka-assembly-*.jar examples/src/main/python/streaming/kafka_wordcount.py \ diff --git a/python/pyspark/serializers.py b/python/pyspark/serializers.py index 4c930d45ee251..2a84635e0c0a1 100644 --- a/python/pyspark/serializers.py +++ b/python/pyspark/serializers.py @@ -146,7 +146,7 @@ def _read_with_length(self, stream): length = read_int(stream) if length == SpecialLengths.END_OF_DATA_SECTION: raise EOFError - if length == SpecialLengths.NULL: + elif length == SpecialLengths.NULL: return None obj = stream.read(length) if len(obj) < length: