http://git-wip-us.apache.org/repos/asf/flink/blob/9b7e4292/test-infra/end-to-end-test/test_streaming_python_wordcount.sh ---------------------------------------------------------------------- diff --git a/test-infra/end-to-end-test/test_streaming_python_wordcount.sh b/test-infra/end-to-end-test/test_streaming_python_wordcount.sh new file mode 100755 index 0000000..a6ef225 --- /dev/null +++ b/test-infra/end-to-end-test/test_streaming_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-stream.sh $FLINK_DIR/examples/python/streaming/word_count.py - --input $TEST_INFRA_DIR/test-data/words --output $TEST_DATA_DIR/out/py_wc_out +check_result_hash "StreamingPythonWordCount" $TEST_DATA_DIR/out/py_wc_out "f6d079fb475e8b745caa6c45b1ac1dff" \ No newline at end of file
http://git-wip-us.apache.org/repos/asf/flink/blob/9b7e4292/tools/maven/suppressions.xml ---------------------------------------------------------------------- diff --git a/tools/maven/suppressions.xml b/tools/maven/suppressions.xml index fdcda52..ae029d6 100644 --- a/tools/maven/suppressions.xml +++ b/tools/maven/suppressions.xml @@ -27,6 +27,14 @@ under the License. <!-- Sometimes we have to temporarily fix very long, different formatted Calcite files. --> <suppress files="org[\\/]apache[\\/]calcite.*" checks="[a-zA-Z0-9]*"/> + <!-- Python streaming API follows python naming conventions --> + <suppress + files="org[\\/]apache[\\/]flink[\\/]streaming[\\/]python[\\/]api[\\/].*.java" + checks="MethodNameCheck|ParameterName"/> + <suppress + files="org[\\/]apache[\\/]flink[\\/]streaming[\\/]python[\\/]connectors[\\/].*.java" + checks="MethodNameCheck|ParameterName"/> + <!-- Cassandra connectors have to use guava directly --> <suppress files="AbstractCassandraTupleSink.java|CassandraInputFormat.java|CassandraOutputFormatBase.java|CassandraSinkBase.java|CassandraSinkBaseTest.java|CassandraPojoSink.java|CassandraRowSink.java|CassandraTupleWriteAheadSink.java|CassandraRowWriteAheadSink.java" http://git-wip-us.apache.org/repos/asf/flink/blob/9b7e4292/tools/travis_mvn_watchdog.sh ---------------------------------------------------------------------- diff --git a/tools/travis_mvn_watchdog.sh b/tools/travis_mvn_watchdog.sh index 9dd8221..71b4115 100755 --- a/tools/travis_mvn_watchdog.sh +++ b/tools/travis_mvn_watchdog.sh @@ -67,6 +67,7 @@ flink-libraries/flink-gelly-scala,\ flink-libraries/flink-gelly-examples,\ flink-libraries/flink-ml,\ flink-libraries/flink-python,\ +flink-libraries/flink-streaming-python,\ flink-libraries/flink-table,\ flink-queryable-state/flink-queryable-state-runtime,\ flink-queryable-state/flink-queryable-state-client-java" @@ -613,7 +614,15 @@ case $TEST in printf "==============================================================================\n" FLINK_DIR=build-target CLUSTER_MODE=cluster test-infra/end-to-end-test/test_shaded_presto_s3.sh EXIT_CODE=$? - fi + fi + + if [ $EXIT_CODE == 0]; then + printf "\n==============================================================================\n" + printf "Running Streaming Python Wordcount end-to-end test\n" + printf "==============================================================================\n" + FLINK_DIR=build-target CLUSTER_MODE=cluster test-infra/end-to-end-test/test_streaming_python_wordcount.sh + EXIT_CODE=$? + fi else printf "\n==============================================================================\n" printf "Previous build failure detected, skipping end-to-end tests.\n"
