This is an automated email from the ASF dual-hosted git repository.
shengkai 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 fa364c7c668 [FLINK-33358][sql-client] Fix Flink SQL Client fail to
start in Flink on YARN (#23629)
fa364c7c668 is described below
commit fa364c7c668ec2a87bcbf18ce2b80f749cc16b2b
Author: Prabhu Joseph <[email protected]>
AuthorDate: Thu Feb 1 09:21:40 2024 +0530
[FLINK-33358][sql-client] Fix Flink SQL Client fail to start in Flink on
YARN (#23629)
Co-authored-by: Prabhu Joseph <[email protected]>
---
flink-table/flink-sql-client/bin/sql-client.sh | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/flink-table/flink-sql-client/bin/sql-client.sh
b/flink-table/flink-sql-client/bin/sql-client.sh
index 3091bdf1b36..797dcc4ac05 100755
--- a/flink-table/flink-sql-client/bin/sql-client.sh
+++ b/flink-table/flink-sql-client/bin/sql-client.sh
@@ -87,7 +87,7 @@ if [[ "$CC_CLASSPATH" =~ .*flink-sql-client.*.jar ]]; then
elif [ -n "$FLINK_SQL_CLIENT_JAR" ]; then
# start client with jar
- exec "$JAVA_RUN" $FLINK_ENV_JAVA_OPTS $JVM_ARGS "${log_setting[@]}"
-classpath "`manglePathList
"$CC_CLASSPATH:$INTERNAL_HADOOP_CLASSPATHS:$FLINK_SQL_CLIENT_JAR"`"
org.apache.flink.table.client.SqlClient "$@" --jar "`manglePath
$FLINK_SQL_CLIENT_JAR`"
+ exec "$JAVA_RUN" $FLINK_ENV_JAVA_OPTS $JVM_ARGS "${log_setting[@]}"
-classpath "`manglePathList
"$CC_CLASSPATH:$FLINK_SQL_CLIENT_JAR:$INTERNAL_HADOOP_CLASSPATHS"`"
org.apache.flink.table.client.SqlClient "$@" --jar "`manglePath
$FLINK_SQL_CLIENT_JAR`"
# write error message to stderr
else
