From 006906db591666a7111066afd226325452be2e3e Mon Sep 17 00:00:00 2001 From: Mark Grover Date: Thu, 21 Jan 2016 21:17:36 -0800 Subject: [SPARK-12960] [PYTHON] Some examples are missing support for python2 Without importing the print_function, the lines later on like ```print("Usage: direct_kafka_wordcount.py ", file=sys.stderr)``` fail when using python2.*. Import fixes that problem and doesn't break anything on python3 either. Author: Mark Grover Closes #10872 from markgrover/python2_compat. --- examples/src/main/python/streaming/direct_kafka_wordcount.py | 1 + .../src/main/python/examples/streaming/kinesis_wordcount_asl.py | 2 ++ 2 files changed, 3 insertions(+) diff --git a/examples/src/main/python/streaming/direct_kafka_wordcount.py b/examples/src/main/python/streaming/direct_kafka_wordcount.py index ea20678b9a..7097f7f450 100644 --- a/examples/src/main/python/streaming/direct_kafka_wordcount.py +++ b/examples/src/main/python/streaming/direct_kafka_wordcount.py @@ -28,6 +28,7 @@ examples/src/main/python/streaming/direct_kafka_wordcount.py \ localhost:9092 test` """ +from __future__ import print_function import sys diff --git a/extras/kinesis-asl/src/main/python/examples/streaming/kinesis_wordcount_asl.py b/extras/kinesis-asl/src/main/python/examples/streaming/kinesis_wordcount_asl.py index f428f64da3..51f8c5ca66 100644 --- a/extras/kinesis-asl/src/main/python/examples/streaming/kinesis_wordcount_asl.py +++ b/extras/kinesis-asl/src/main/python/examples/streaming/kinesis_wordcount_asl.py @@ -54,6 +54,8 @@ See http://spark.apache.org/docs/latest/streaming-kinesis-integration.html for more details on the Kinesis Spark Streaming integration. """ +from __future__ import print_function + import sys from pyspark import SparkContext -- cgit v1.2.3