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: 黄培松 <bringt...@qq.com> 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)