You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by di...@apache.org on 2020/05/15 01:55:49 UTC
[flink] branch master updated: [FLINK-12717][python] Remove script
pyflink-gateway-server.sh which has been replaced with
pyflink_gateway_server.py
This is an automated email from the ASF dual-hosted git repository.
dianfu 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 ed3817b [FLINK-12717][python] Remove script pyflink-gateway-server.sh which has been replaced with pyflink_gateway_server.py
ed3817b is described below
commit ed3817b1cfa0c4614a3cca953502a7c128e9a594
Author: Wei Zhong <we...@gmail.com>
AuthorDate: Wed May 13 19:38:46 2020 +0800
[FLINK-12717][python] Remove script pyflink-gateway-server.sh which has been replaced with pyflink_gateway_server.py
This closes #12125.
---
flink-python/bin/pyflink-gateway-server.sh | 106 -----------------------------
1 file changed, 106 deletions(-)
diff --git a/flink-python/bin/pyflink-gateway-server.sh b/flink-python/bin/pyflink-gateway-server.sh
deleted file mode 100644
index b19dfed..0000000
--- a/flink-python/bin/pyflink-gateway-server.sh
+++ /dev/null
@@ -1,106 +0,0 @@
-#!/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.
-################################################################################
-
-# =====================================================================
-bin=`dirname "$0"`
-bin=`cd "$bin"; pwd`
-
-. "$bin"/config.sh
-
-if [ "$FLINK_IDENT_STRING" = "" ]; then
- FLINK_IDENT_STRING="$USER"
-fi
-
-FLINK_CLASSPATH=`constructFlinkClassPath`
-
-ARGS=()
-
-while [[ $# -gt 0 ]]
-do
- key="$1"
- case $key in
- -c|--class)
- DRIVER=$2
- shift
- shift
- ;;
- *)
- ARGS+=("$1")
- shift
- ;;
- esac
-done
-
-log=$FLINK_LOG_DIR/flink-$FLINK_IDENT_STRING-python-$HOSTNAME.log
-log_setting=(-Dlog.file="$log" -Dlog4j.configuration=file:"$FLINK_CONF_DIR"/log4j-cli.properties -Dlog4j.configurationFile=file:"$FLINK_CONF_DIR"/log4j-cli.properties -Dlogback.configurationFile=file:"$FLINK_CONF_DIR"/logback.xml)
-
-PYTHON_JAR_PATH=`echo "$FLINK_HOME"/opt/flink-python*.jar`
-
-FLINK_TEST_CLASSPATH=""
-if [[ -n "$FLINK_TESTING" ]]; then
- bin=`dirname "$0"`
- CURRENT_DIR=`pwd -P`
- cd "$bin/../../"
- FLINK_SOURCE_ROOT_DIR=`pwd -P`
-
- # Downloads avro as it is needed by the unit test
- AVRO_VERSION=`mvn help:evaluate -Dexpression=avro.version | grep --invert-match -E '\[|Download*'`
- if [[ ! -f ${FLINK_SOURCE_ROOT_DIR}/flink-formats/flink-avro/target/avro-"$AVRO_VERSION".jar ]]; then
- mvn org.apache.maven.plugins:maven-dependency-plugin:2.10:copy -Dartifact=org.apache.avro:avro:"$AVRO_VERSION":jar -DoutputDirectory=$FLINK_SOURCE_ROOT_DIR/flink-formats/flink-avro/target > /dev/null 2>&1
- if [[ ! -f ${FLINK_SOURCE_ROOT_DIR}/flink-formats/flink-avro/target/avro-"$AVRO_VERSION".jar ]]; then
- echo "Download avro-$AVRO_VERSION.jar failed."
- fi
- fi
-
- FIND_EXPRESSION=""
- FIND_EXPRESSION="$FIND_EXPRESSION -path ${FLINK_SOURCE_ROOT_DIR}/flink-table/flink-table-planner/target/flink-table-planner*-tests.jar"
- FIND_EXPRESSION="$FIND_EXPRESSION -o -path ${FLINK_SOURCE_ROOT_DIR}/flink-runtime/target/flink-runtime*tests.jar"
- FIND_EXPRESSION="$FIND_EXPRESSION -o -path ${FLINK_SOURCE_ROOT_DIR}/flink-streaming-java/target/flink-streaming-java*tests.jar"
- FIND_EXPRESSION="$FIND_EXPRESSION -o -path ${FLINK_SOURCE_ROOT_DIR}/flink-formats/flink-csv/target/flink-csv*.jar"
- FIND_EXPRESSION="$FIND_EXPRESSION -o -path ${FLINK_SOURCE_ROOT_DIR}/flink-formats/flink-avro/target/flink-avro*.jar"
- FIND_EXPRESSION="$FIND_EXPRESSION -o -path ${FLINK_SOURCE_ROOT_DIR}/flink-formats/flink-avro/target/avro*.jar"
- FIND_EXPRESSION="$FIND_EXPRESSION -o -path ${FLINK_SOURCE_ROOT_DIR}/flink-formats/flink-json/target/flink-json*.jar"
- FIND_EXPRESSION="$FIND_EXPRESSION -o -path ${FLINK_SOURCE_ROOT_DIR}/flink-connectors/flink-connector-elasticsearch-base/target/flink*.jar"
- FIND_EXPRESSION="$FIND_EXPRESSION -o -path ${FLINK_SOURCE_ROOT_DIR}/flink-connectors/flink-connector-kafka-base/target/flink*.jar"
- FIND_EXPRESSION="$FIND_EXPRESSION -o -path ${FLINK_SOURCE_ROOT_DIR}/flink-ml-parent/flink-ml-api/target/flink-ml-api*.jar"
- FIND_EXPRESSION="$FIND_EXPRESSION -o -path ${FLINK_SOURCE_ROOT_DIR}/flink-ml-parent/flink-ml-lib/target/flink-ml-lib*.jar"
- FIND_EXPRESSION="$FIND_EXPRESSION -o -path ${FLINK_SOURCE_ROOT_DIR}/flink-connectors/flink-connector-hbase/target/flink*.jar"
-
- # disable the wildcard expansion for the moment.
- set -f
- while read -d '' -r testJarFile ; do
- if [[ "$FLINK_TEST_CLASSPATH" == "" ]]; then
- FLINK_TEST_CLASSPATH="$testJarFile";
- else
- FLINK_TEST_CLASSPATH="$FLINK_TEST_CLASSPATH":"$testJarFile"
- fi
- done < <(find "$FLINK_SOURCE_ROOT_DIR" ! -type d \( ${FIND_EXPRESSION} \) -print0 | sort -z)
- set +f
-
- cd $CURRENT_DIR
-fi
-
-ARGS_COUNT=${#ARGS[@]}
-if [[ ${ARGS[0]} == "local" ]]; then
- ARGS=("${ARGS[@]:1:$ARGS_COUNT}")
- exec $JAVA_RUN $JVM_ARGS "${log_setting[@]}" -cp ${FLINK_CLASSPATH}:${PYTHON_JAR_PATH}:${FLINK_TEST_CLASSPATH} ${DRIVER} ${ARGS[@]}
-else
- ARGS=("${ARGS[@]:1:$ARGS_COUNT}")
- exec "$FLINK_BIN_DIR"/flink run ${ARGS[@]} -c ${DRIVER}
-fi