This is an automated email from the ASF dual-hosted git repository.
srowen pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/spark.git
The following commit(s) were added to refs/heads/master by this push:
new d6ee2f3 [MINOR][EXAMPLES] Add missing return keyword streaming word
count example
d6ee2f3 is described below
commit d6ee2f331db461c1f7a25e0ef17901f53d8b707e
Author: Ruocheng Jiang <jiangruoch...@gmail.com>
AuthorDate: Wed Mar 20 17:59:12 2019 -0500
[MINOR][EXAMPLES] Add missing return keyword streaming word count example
This is a very low level error.
Closes #24153 from jiangruocheng/master.
Authored-by: Ruocheng Jiang <jiangruoch...@gmail.com>
Signed-off-by: Sean Owen <sean.o...@databricks.com>
---
examples/src/main/python/streaming/recoverable_network_wordcount.py | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/examples/src/main/python/streaming/recoverable_network_wordcount.py
b/examples/src/main/python/streaming/recoverable_network_wordcount.py
index 60167dc..a39c4d0 100644
--- a/examples/src/main/python/streaming/recoverable_network_wordcount.py
+++ b/examples/src/main/python/streaming/recoverable_network_wordcount.py
@@ -83,9 +83,9 @@ def createContext(host, port, outputPath):
def filterFunc(wordCount):
if wordCount[0] in blacklist.value:
droppedWordsCounter.add(wordCount[1])
- False
+ return False
else:
- True
+ return True
counts = "Counts at time %s %s" % (time,
rdd.filter(filterFunc).collect())
print(counts)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@spark.apache.org
For additional commands, e-mail: commits-h...@spark.apache.org
