From 191650f7c0e0f17cbd1035759bbcec28ede01d87 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=D0=9C=D1=83=D1=85=D1=83=D1=82=D0=B4=D0=B8=D0=BD=D0=BE?= =?UTF-8?q?=D0=B2=20=D0=90=D1=80=D1=82=D1=83=D1=80?= Date: Sat, 2 Aug 2025 21:59:01 +0300 Subject: [PATCH] feat: update flink-cdc.sh Updated initial bash script to handle all .jar files even inside subdirectories --- flink-cdc-dist/src/main/flink-cdc-bin/bin/flink-cdc.sh | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/flink-cdc-dist/src/main/flink-cdc-bin/bin/flink-cdc.sh b/flink-cdc-dist/src/main/flink-cdc-bin/bin/flink-cdc.sh index 78c9439c512..a7d63c123a1 100644 --- a/flink-cdc-dist/src/main/flink-cdc-bin/bin/flink-cdc.sh +++ b/flink-cdc-dist/src/main/flink-cdc-bin/bin/flink-cdc.sh @@ -64,11 +64,11 @@ FLINK_CDC_LOG="$FLINK_CDC_HOME"/log # Build Java classpath CLASSPATH="" # Add Flink libraries to the classpath -for jar in "$FLINK_HOME"/lib/*.jar; do +for jar in $(find "$FLINK_HOME"/lib -name "*.jar" -type f); do CLASSPATH=$CLASSPATH:$jar done # Add Flink CDC libraries to classpath -for jar in "$FLINK_CDC_LIB"/*.jar; do +for jar in $(find "$FLINK_CDC_LIB" -name "*.jar" -type f); do CLASSPATH=$CLASSPATH:$jar done # Add Hadoop classpath, which is defined in config.sh