Skip to content

Commit 048dbe6

Browse files
author
Davies Liu
committed
fix python style
1 parent 75d485e commit 048dbe6

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

python/pyspark/streaming/kafka.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -52,7 +52,8 @@ def createStream(ssc, zkQuorum, groupId, topics,
5252
jtopics = MapConverter().convert(topics, ssc.sparkContext._gateway._gateway_client)
5353
jlevel = ssc._sc._getJavaStorageLevel(storageLevel)
5454
try:
55-
jstream = ssc._jvm.KafkaUtils.createStream(ssc._jssc, zkQuorum, groupId, jtopics, jlevel)
55+
jstream = ssc._jvm.KafkaUtils.createStream(ssc._jssc, zkQuorum, groupId, jtopics,
56+
jlevel)
5657
except Py4JError, e:
5758
if 'call a package' in e.message:
5859
print "No kafka package, please build it and add it into classpath:"

0 commit comments

Comments
 (0)