You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2018/06/12 09:43:00 UTC
flink git commit: [FLINK-9368][py][tests] Add Python API E2E test
Repository: flink
Updated Branches:
refs/heads/master 0f5cf7b15 -> 2b33615b6
[FLINK-9368][py][tests] Add Python API E2E test
This closes #6127.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2b33615b
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/2b33615b
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/2b33615b
Branch: refs/heads/master
Commit: 2b33615b60f7618676f2dcae50c85ea356e27896
Parents: 0f5cf7b
Author: zentol <ch...@apache.org>
Authored: Tue May 15 14:24:51 2018 +0200
Committer: zentol <ch...@apache.org>
Committed: Tue Jun 12 11:42:49 2018 +0200
----------------------------------------------------------------------
flink-end-to-end-tests/run-pre-commit-tests.sh | 5 ++++
.../test-scripts/test_batch_python_wordcount.sh | 25 ++++++++++++++++++++
2 files changed, 30 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/2b33615b/flink-end-to-end-tests/run-pre-commit-tests.sh
----------------------------------------------------------------------
diff --git a/flink-end-to-end-tests/run-pre-commit-tests.sh b/flink-end-to-end-tests/run-pre-commit-tests.sh
index 50b1430..4d63397 100755
--- a/flink-end-to-end-tests/run-pre-commit-tests.sh
+++ b/flink-end-to-end-tests/run-pre-commit-tests.sh
@@ -49,6 +49,11 @@ EXIT_CODE=0
# fi
if [ $EXIT_CODE == 0 ]; then
+ run_test "Batch Python Wordcount end-to-end test" "$END_TO_END_DIR/test-scripts/test_batch_python_wordcount.sh"
+ EXIT_CODE=$?
+fi
+
+if [ $EXIT_CODE == 0 ]; then
run_test "Streaming Python Wordcount end-to-end test" "$END_TO_END_DIR/test-scripts/test_streaming_python_wordcount.sh"
EXIT_CODE=$?
fi
http://git-wip-us.apache.org/repos/asf/flink/blob/2b33615b/flink-end-to-end-tests/test-scripts/test_batch_python_wordcount.sh
----------------------------------------------------------------------
diff --git a/flink-end-to-end-tests/test-scripts/test_batch_python_wordcount.sh b/flink-end-to-end-tests/test-scripts/test_batch_python_wordcount.sh
new file mode 100755
index 0000000..409644c
--- /dev/null
+++ b/flink-end-to-end-tests/test-scripts/test_batch_python_wordcount.sh
@@ -0,0 +1,25 @@
+#!/usr/bin/env bash
+################################################################################
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements. See the NOTICE file
+# distributed with this work for additional information
+# regarding copyright ownership. The ASF licenses this file
+# to you under the Apache License, Version 2.0 (the
+# "License"); you may not use this file except in compliance
+# with the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+################################################################################
+
+source "$(dirname "$0")"/common.sh
+
+start_cluster
+
+$FLINK_DIR/bin/pyflink.sh $FLINK_DIR/examples/python/batch/WordCount.py - $TEST_INFRA_DIR/test-data/words $TEST_DATA_DIR/out/py_wc_out
+check_result_hash "BatchPythonWordCount" $TEST_DATA_DIR/out/py_wc_out "dd9d7a7bbc8b52747c7d4e15c9d2b069"