We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 087195a commit 6b13868Copy full SHA for 6b13868
flink-cdc-dist/src/main/flink-cdc-bin/bin/flink-cdc.sh
@@ -21,9 +21,20 @@ args=("$@")
21
# Check if FLINK_HOME is set in command-line arguments by "--flink-home"
22
for ((i=0; i < ${#args[@]}; i++)); do
23
case "${args[i]}" in
24
+ --flink-home=*)
25
+ # Extract the value after "="
26
+ FLINK_HOME_VALUE="${args[i]#*=}"
27
+ # Check if the value is not empty
28
+ if [[ -n "$FLINK_HOME_VALUE" ]]; then
29
+ FLINK_HOME="$FLINK_HOME_VALUE"
30
+ echo "[INFO] Set FLINK_HOME to ${FLINK_HOME_VALUE}."
31
+ break
32
+ fi
33
+ ;;
34
--flink-home)
35
if [[ -n "${args[i+1]}" ]]; then
36
FLINK_HOME="${args[i+1]}"
37
+ echo "[INFO] Set FLINK_HOME to ${FLINK_HOME}."
38
break
39
fi
40
;;
0 commit comments