[flink] 05/09: [Flink-15135][e2e][Mesos] Adding WordCount e2e test for Flink on Mesos

[tr...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

trohrmann pushed a commit to branch release-1.10
in repository https://gitbox.apache.org/repos/asf/flink.git

commit 66720d042a80dddd8c2c754cdd9c7bf41e38dceb
Author: Yangze Guo <ka...@gmail.com>
AuthorDate: Thu Dec 12 11:08:24 2019 +0800

    [Flink-15135][e2e][Mesos] Adding WordCount e2e test for Flink on Mesos
---
 .../test-scripts/test_mesos_wordcount.sh           | 36 ++++++++++++++++++++++
 1 file changed, 36 insertions(+)

diff --git a/flink-end-to-end-tests/test-scripts/test_mesos_wordcount.sh b/flink-end-to-end-tests/test-scripts/test_mesos_wordcount.sh
new file mode 100755
index 0000000..d2f5c40
--- /dev/null
+++ b/flink-end-to-end-tests/test-scripts/test_mesos_wordcount.sh
@@ -0,0 +1,36 @@
+#!/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.
+################################################################################
+
+set -o pipefail
+
+source "$(dirname "$0")"/common.sh
+source "$(dirname "$0")"/common_mesos_docker.sh
+
+RESULT_HASH="72a690412be8928ba239c2da967328a5"
+INPUT_ARGS="--input ${TEST_INFRA_DIR}/test-data/words"
+OUTPUT_LOCATION="${TEST_DATA_DIR}/out/wc_out_mesos"
+TEST_PROGRAM_JAR=${FLINK_DIR}/examples/batch/WordCount.jar
+
+mkdir -p "${TEST_DATA_DIR}"
+
+start_flink_cluster_with_mesos
+
+docker exec -it mesos-master nohup bash -c "${FLINK_DIR}/bin/flink run -p 1 ${TEST_PROGRAM_JAR} ${INPUT_ARGS} --output ${OUTPUT_LOCATION}"
+
+check_result_hash "Mesos WordCount test" "${OUTPUT_LOCATION}" "${RESULT_HASH}"