From a5684cd10274313c21ae9a7bb3e4941bf00ce2d8 Mon Sep 17 00:00:00 2001
From: zentol <chesnay@apache.org>
Date: Tue, 15 May 2018 14:24:51 +0200
Subject: [PATCH] [FLINK-9368][py][tests] Add Python API E2E test

---
 .../run-pre-commit-tests.sh                   |  5 ++++
 .../test_batch_python_wordcount.sh            | 25 +++++++++++++++++++
 2 files changed, 30 insertions(+)
 create mode 100755 flink-end-to-end-tests/test-scripts/test_batch_python_wordcount.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 8c82e2eecb123..4342e440d9cab 100755
--- a/flink-end-to-end-tests/run-pre-commit-tests.sh
+++ b/flink-end-to-end-tests/run-pre-commit-tests.sh
@@ -46,6 +46,11 @@ EXIT_CODE=0
 #    EXIT_CODE=$?
 # 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=$?
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 0000000000000..409644c51e219
--- /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"