Skip to content

Commit 23b039a

Browse files
author
Davies Liu
committed
address comments
1 parent 9af51c4 commit 23b039a

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

examples/src/main/python/streaming/kafka_wordcount.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@
2121
2222
To run this on your local machine, you need to setup Kafka and create a producer first, see
2323
http://kafka.apache.org/documentation.html#quickstart
24-
24+
2525
and then run the example
2626
`$ bin/spark-submit --driver-class-path external/kafka-assembly/target/scala-*/\
2727
spark-streaming-kafka-assembly-*.jar examples/src/main/python/streaming/kafka_wordcount.py \

python/pyspark/serializers.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -146,7 +146,7 @@ def _read_with_length(self, stream):
146146
length = read_int(stream)
147147
if length == SpecialLengths.END_OF_DATA_SECTION:
148148
raise EOFError
149-
if length == SpecialLengths.NULL:
149+
elif length == SpecialLengths.NULL:
150150
return None
151151
obj = stream.read(length)
152152
if len(obj) < length:

0 commit comments

Comments
 (0)