You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by sr...@apache.org on 2019/03/20 22:59:30 UTC
[spark] branch master updated: [MINOR][EXAMPLES] Add missing return
keyword streaming word count example
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 <ji...@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 <ji...@gmail.com>
Signed-off-by: Sean Owen <se...@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-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org