Skip to content

Commit d6ee2f3

Browse files
jiangruochengsrowen
authored andcommitted
[MINOR][EXAMPLES] Add missing return keyword streaming word count example
This is a very low level error. Closes apache#24153 from jiangruocheng/master. Authored-by: Ruocheng Jiang <[email protected]> Signed-off-by: Sean Owen <[email protected]>
1 parent a8d9531 commit d6ee2f3

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

examples/src/main/python/streaming/recoverable_network_wordcount.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -83,9 +83,9 @@ def echo(time, rdd):
8383
def filterFunc(wordCount):
8484
if wordCount[0] in blacklist.value:
8585
droppedWordsCounter.add(wordCount[1])
86-
False
86+
return False
8787
else:
88-
True
88+
return True
8989

9090
counts = "Counts at time %s %s" % (time, rdd.filter(filterFunc).collect())
9191
print(counts)

0 commit comments

Comments
 (0)