Skip to content

Commit 583e66d

Browse files
committed
move tests for streaming inside streaming directory
1 parent 1d84142 commit 583e66d

File tree

2 files changed

+1
-1
lines changed

2 files changed

+1
-1
lines changed

python/pyspark/streaming/dstream.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -216,7 +216,7 @@ def getNumPartitions(self):
216216
"""
217217
Return the number of partitions in RDD
218218
"""
219-
# TODO: remove hardcoding. RDD has NumPartitions. How do we get the number of partition
219+
# TODO: remove hard coding. RDD has NumPartitions. How do we get the number of partition
220220
# through DStream?
221221
return 2
222222

File renamed without changes.

0 commit comments

Comments
 (0)