Skip to content

Commit bfae0ab

Browse files
committed
Fix style issue
1 parent 3ff4b09 commit bfae0ab

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

python/pyspark/streaming/tests.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1161,6 +1161,7 @@ def test_kafka_direct_stream_transform_with_checkpoint(self):
11611161
self._kafkaTestUtils.sendMessages(topic, sendData)
11621162

11631163
offsetRanges = []
1164+
11641165
def transformWithOffsetRanges(rdd):
11651166
for o in rdd.offsetRanges():
11661167
offsetRanges.append(o)
@@ -1169,6 +1170,7 @@ def transformWithOffsetRanges(rdd):
11691170
self.ssc.stop(False)
11701171
self.ssc = None
11711172
tmpdir = "checkpoint-test-%d" % random.randint(0, 10000)
1173+
11721174
def setup():
11731175
ssc = StreamingContext(self.sc, 0.5)
11741176
ssc.checkpoint(tmpdir)

0 commit comments

Comments
 (0)