Skip to content

Commit

Permalink
[hotfix][dist] Rename FLINK_ROOT*_DIR to FLINK_HOME
Browse files Browse the repository at this point in the history
The same concept of Flink's root/home directory was named in different places differently.
This commit unifies the naming convention to FLINK_HOME by renaming FLINK_ROOT_DIR and FLINK_HOME_DIR to FLINK_HOME.
  • Loading branch information
pnowojski committed Jun 13, 2019
1 parent 00d90a4 commit d14117f
Show file tree
Hide file tree
Showing 9 changed files with 21 additions and 21 deletions.
14 changes: 7 additions & 7 deletions flink-dist/src/main/flink-bin/bin/config.sh
Original file line number Diff line number Diff line change
Expand Up @@ -296,9 +296,9 @@ bin=`dirname "$target"`
SYMLINK_RESOLVED_BIN=`cd "$bin"; pwd -P`

# Define the main directory of the flink installation
FLINK_ROOT_DIR=`dirname "$SYMLINK_RESOLVED_BIN"`
FLINK_LIB_DIR=$FLINK_ROOT_DIR/lib
FLINK_OPT_DIR=$FLINK_ROOT_DIR/opt
FLINK_HOME=`dirname "$SYMLINK_RESOLVED_BIN"`
FLINK_LIB_DIR=$FLINK_HOME/lib
FLINK_OPT_DIR=$FLINK_HOME/opt

### Exported environment variables ###
export FLINK_CONF_DIR
Expand All @@ -310,10 +310,10 @@ export FLINK_OPT_DIR
# These need to be mangled because they are directly passed to java.
# The above lib path is used by the shell script to retrieve jars in a
# directory, so it needs to be unmangled.
FLINK_ROOT_DIR_MANGLED=`manglePath "$FLINK_ROOT_DIR"`
if [ -z "$FLINK_CONF_DIR" ]; then FLINK_CONF_DIR=$FLINK_ROOT_DIR_MANGLED/conf; fi
FLINK_BIN_DIR=$FLINK_ROOT_DIR_MANGLED/bin
DEFAULT_FLINK_LOG_DIR=$FLINK_ROOT_DIR_MANGLED/log
FLINK_HOME_DIR_MANGLED=`manglePath "$FLINK_HOME"`
if [ -z "$FLINK_CONF_DIR" ]; then FLINK_CONF_DIR=$FLINK_HOME_DIR_MANGLED/conf; fi
FLINK_BIN_DIR=$FLINK_HOME_DIR_MANGLED/bin
DEFAULT_FLINK_LOG_DIR=$FLINK_HOME_DIR_MANGLED/log
FLINK_CONF_FILE="flink-conf.yaml"
YAML_CONF=${FLINK_CONF_DIR}/${FLINK_CONF_FILE}

Expand Down
2 changes: 1 addition & 1 deletion flink-dist/src/main/flink-bin/bin/flink
Original file line number Diff line number Diff line change
Expand Up @@ -48,7 +48,7 @@ CC_CLASSPATH=`constructFlinkClassPath`
log=$FLINK_LOG_DIR/flink-$FLINK_IDENT_STRING-client-$HOSTNAME.log
log_setting=(-Dlog.file="$log" -Dlog4j.configuration=file:"$FLINK_CONF_DIR"/log4j-cli.properties -Dlogback.configurationFile=file:"$FLINK_CONF_DIR"/logback.xml)

export FLINK_ROOT_DIR
export FLINK_HOME
export FLINK_CONF_DIR

# Add HADOOP_CLASSPATH to allow the usage of Hadoop file systems
Expand Down
4 changes: 2 additions & 2 deletions flink-dist/src/main/flink-bin/bin/flink.bat
Original file line number Diff line number Diff line change
Expand Up @@ -20,8 +20,8 @@
setlocal

SET bin=%~dp0
SET FLINK_ROOT_DIR=%bin%..
SET FLINK_LIB_DIR=%FLINK_ROOT_DIR%\lib
SET FLINK_HOME=%bin%..
SET FLINK_LIB_DIR=%FLINK_HOME%\lib

SET JVM_ARGS=-Xmx512m

Expand Down
4 changes: 2 additions & 2 deletions flink-dist/src/main/flink-bin/bin/pyflink-gateway-server.sh
Original file line number Diff line number Diff line change
Expand Up @@ -50,8 +50,8 @@ 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 -Dlogback.configurationFile=file:"$FLINK_CONF_DIR"/logback.xml)

TABLE_JAR_PATH=`echo "$FLINK_ROOT_DIR"/opt/flink-table*.jar`
PYTHON_JAR_PATH=`echo "$FLINK_ROOT_DIR"/opt/flink-python*java-binding.jar`
TABLE_JAR_PATH=`echo "$FLINK_HOME"/opt/flink-table*.jar`
PYTHON_JAR_PATH=`echo "$FLINK_HOME"/opt/flink-python*java-binding.jar`

FLINK_TEST_CLASSPATH=""
if [[ -n "$FLINK_TESTING" ]]; then
Expand Down
2 changes: 1 addition & 1 deletion flink-dist/src/main/flink-bin/bin/pyflink-stream.sh
Original file line number Diff line number Diff line change
Expand Up @@ -22,4 +22,4 @@ bin=`cd "$bin"; pwd`

. "$bin"/config.sh

"$FLINK_BIN_DIR"/flink run --class org.apache.flink.streaming.python.api.PythonStreamBinder -v "$FLINK_ROOT_DIR"/opt/flink-streaming-python*.jar "$@"
"$FLINK_BIN_DIR"/flink run --class org.apache.flink.streaming.python.api.PythonStreamBinder -v "$FLINK_HOME"/opt/flink-streaming-python*.jar "$@"
4 changes: 2 additions & 2 deletions flink-dist/src/main/flink-bin/bin/pyflink.bat
Original file line number Diff line number Diff line change
Expand Up @@ -20,6 +20,6 @@
setlocal EnableDelayedExpansion

SET bin=%~dp0
SET FLINK_ROOT_DIR=%bin%..
SET FLINK_HOME=%bin%..

"%FLINK_ROOT_DIR%\bin\flink" run -v "%FLINK_ROOT_DIR%"\opt\flink-python*.jar %*
"%FLINK_HOME%\bin\flink" run -v "%FLINK_HOME%"\opt\flink-python*.jar %*
2 changes: 1 addition & 1 deletion flink-dist/src/main/flink-bin/bin/pyflink.sh
Original file line number Diff line number Diff line change
Expand Up @@ -22,4 +22,4 @@ bin=`cd "$bin"; pwd`

. "$bin"/config.sh

"$FLINK_BIN_DIR"/flink run -v "$FLINK_ROOT_DIR"/opt/flink-python_*.jar "$@"
"$FLINK_BIN_DIR"/flink run -v "$FLINK_HOME"/opt/flink-python_*.jar "$@"
8 changes: 4 additions & 4 deletions flink-dist/src/main/flink-bin/bin/start-cluster.bat
Original file line number Diff line number Diff line change
Expand Up @@ -20,10 +20,10 @@
setlocal EnableDelayedExpansion

SET bin=%~dp0
SET FLINK_ROOT_DIR=%bin%..
SET FLINK_LIB_DIR=%FLINK_ROOT_DIR%\lib
SET FLINK_CONF_DIR=%FLINK_ROOT_DIR%\conf
SET FLINK_LOG_DIR=%FLINK_ROOT_DIR%\log
SET FLINK_HOME=%bin%..
SET FLINK_LIB_DIR=%FLINK_HOME%\lib
SET FLINK_CONF_DIR=%FLINK_HOME%\conf
SET FLINK_LOG_DIR=%FLINK_HOME%\log

SET JVM_ARGS=-Xms1024m -Xmx1024m

Expand Down
2 changes: 1 addition & 1 deletion flink-table/flink-sql-client/bin/sql-client.sh
Original file line number Diff line number Diff line change
Expand Up @@ -56,7 +56,7 @@ CC_CLASSPATH=`constructFlinkClassPath`
log=$FLINK_LOG_DIR/flink-$FLINK_IDENT_STRING-sql-client-$HOSTNAME.log
log_setting=(-Dlog.file="$log" -Dlog4j.configuration=file:"$FLINK_CONF_DIR"/log4j-cli.properties -Dlogback.configurationFile=file:"$FLINK_CONF_DIR"/logback.xml)

export FLINK_ROOT_DIR
export FLINK_HOME
export FLINK_CONF_DIR

# get path of jar in /opt if it exist
Expand Down

0 comments on commit d14117f

Please sign in to comment.