From 048dbe6c9ec4bff4eeee52c70e4e18d48d3075e0 Mon Sep 17 00:00:00 2001 From: Davies Liu Date: Tue, 16 Dec 2014 14:27:43 -0800 Subject: [PATCH] fix python style --- python/pyspark/streaming/kafka.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/python/pyspark/streaming/kafka.py b/python/pyspark/streaming/kafka.py index ed52f853658fd..24d62db1979b9 100644 --- a/python/pyspark/streaming/kafka.py +++ b/python/pyspark/streaming/kafka.py @@ -52,7 +52,8 @@ def createStream(ssc, zkQuorum, groupId, topics, jtopics = MapConverter().convert(topics, ssc.sparkContext._gateway._gateway_client) jlevel = ssc._sc._getJavaStorageLevel(storageLevel) try: - jstream = ssc._jvm.KafkaUtils.createStream(ssc._jssc, zkQuorum, groupId, jtopics, jlevel) + jstream = ssc._jvm.KafkaUtils.createStream(ssc._jssc, zkQuorum, groupId, jtopics, + jlevel) except Py4JError, e: if 'call a package' in e.message: print "No kafka package, please build it and add it into classpath:"