We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent cabfd30 commit 26d987aCopy full SHA for 26d987a
1 file changed
flink-cdc-dist/src/main/flink-cdc-bin/bin/flink-cdc.sh
@@ -64,11 +64,11 @@ FLINK_CDC_LOG="$FLINK_CDC_HOME"/log
64
# Build Java classpath
65
CLASSPATH=""
66
# Add Flink libraries to the classpath
67
-for jar in "$FLINK_HOME"/lib/*.jar; do
+for jar in $(find "$FLINK_HOME"/lib -name "*.jar" -type f); do
68
CLASSPATH=$CLASSPATH:$jar
69
done
70
# Add Flink CDC libraries to classpath
71
-for jar in "$FLINK_CDC_LIB"/*.jar; do
+for jar in $(find "$FLINK_CDC_LIB" -name "*.jar" -type f); do
72
73
74
# Add Hadoop classpath, which is defined in config.sh
0 commit comments