diff --git a/flink-dist/src/main/flink-bin/bin/config.sh b/flink-dist/src/main/flink-bin/bin/config.sh index 88661547dd48c..cbb1fc7623b1e 100755 --- a/flink-dist/src/main/flink-bin/bin/config.sh +++ b/flink-dist/src/main/flink-bin/bin/config.sh @@ -48,19 +48,19 @@ constructFlinkClassPath() { } # baisui add for 找到除flink开头的jar包,因为k8s application 模式下运行,在flink-dependency 包中都已经有flink相关的依赖了 -constructTISKubernetesApplicationFlinkClassPath() { - local FLINK_CLASSPATH - # 找到除flink开头的jar包 - while read -d '' -r jarfile ; do - if [[ "$FLINK_CLASSPATH" == "" ]]; then - FLINK_CLASSPATH="$jarfile"; - else - FLINK_CLASSPATH="$FLINK_CLASSPATH":"$jarfile" - fi - done < <(find "$FLINK_LIB_DIR" ! -type d ! -name 'flink-*.jar' -print0 | sort -z) - - echo "$FLINK_CLASSPATH" -} +#constructTISKubernetesApplicationFlinkClassPath() { +# local FLINK_CLASSPATH +# # 找到除flink开头的jar包 +# while read -d '' -r jarfile ; do +# if [[ "$FLINK_CLASSPATH" == "" ]]; then +# FLINK_CLASSPATH="$jarfile"; +# else +# FLINK_CLASSPATH="$FLINK_CLASSPATH":"$jarfile" +# fi +# done < <(find "$FLINK_LIB_DIR" ! -type d ! -name 'flink-*.jar' -print0 | sort -z) +# +# echo "$FLINK_CLASSPATH" +#} findFlinkDistJar() { local FLINK_DIST diff --git a/flink-dist/src/main/flink-bin/bin/flink-console.sh b/flink-dist/src/main/flink-bin/bin/flink-console.sh index d0939f407cb37..cd021e9226433 100755 --- a/flink-dist/src/main/flink-bin/bin/flink-console.sh +++ b/flink-dist/src/main/flink-bin/bin/flink-console.sh @@ -56,7 +56,7 @@ case $SERVICE in (kubernetes-application) # baisui modify for tis entrypoint 2024/01/09 - FLINK_TM_CLASSPATH=`constructTISKubernetesApplicationFlinkClassPath` + # FLINK_TM_CLASSPATH=`constructTISKubernetesApplicationFlinkClassPath` CLASS_TO_RUN=org.apache.flink.kubernetes.entrypoint.KubernetesApplicationClusterEntrypointOfTIS ;;