This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 0261417 [hotfix][py] Fix typo in Python examples
0261417 is described below
commit 026141744e09c22a60fb975ff502629168a41d43
Author: 黄培松 <[email protected]>
AuthorDate: Wed Jun 12 16:54:29 2019 +0800
[hotfix][py] Fix typo in Python examples
This closes #8705.
---
.../org/apache/flink/python/api/flink/example/WebLogAnalysis.py | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/flink-libraries/flink-python/src/main/python/org/apache/flink/python/api/flink/example/WebLogAnalysis.py
b/flink-libraries/flink-python/src/main/python/org/apache/flink/python/api/flink/example/WebLogAnalysis.py
index 1ea3e78..9e3c0b3 100644
---
a/flink-libraries/flink-python/src/main/python/org/apache/flink/python/api/flink/example/WebLogAnalysis.py
+++
b/flink-libraries/flink-python/src/main/python/org/apache/flink/python/api/flink/example/WebLogAnalysis.py
@@ -51,7 +51,7 @@ if __name__ == "__main__":
env = get_environment()
if len(sys.argv) != 5:
- sys.exit("Usage: ./bin/pyflink.sh WebLogAnalysis <docments path> <ranks
path> <visits path> <output path>")
+ sys.exit("Usage: ./bin/pyflink.sh WebLogAnalysis <documents path>
<ranks path> <visits path> <output path>")
documents = env \
.read_csv(sys.argv[1], "\n", "|") \
@@ -84,4 +84,4 @@ if __name__ == "__main__":
env.set_parallelism(1)
- env.execute(local=True)
\ No newline at end of file
+ env.execute(local=True)