From 6b13868dd5ac7474c946bdc41005feed616d9be8 Mon Sep 17 00:00:00 2001
From: Jzjsnow <5797454@qq.com>
Date: Thu, 16 Jan 2025 18:08:57 +0800
Subject: [PATCH] [FLINK-36620][cdc-cli] Add support for specifying the
 --flink-home parameter via an '=' character

This closes #3838
---
 .../src/main/flink-cdc-bin/bin/flink-cdc.sh           | 11 +++++++++++
 1 file changed, 11 insertions(+)

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 6875c1c81..78c9439c5 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
@@ -21,9 +21,20 @@ args=("$@")
 # Check if FLINK_HOME is set in command-line arguments by "--flink-home"
 for ((i=0; i < ${#args[@]}; i++)); do
     case "${args[i]}" in
+        --flink-home=*)
+            # Extract the value after "="
+            FLINK_HOME_VALUE="${args[i]#*=}"
+            # Check if the value is not empty
+            if [[ -n "$FLINK_HOME_VALUE" ]]; then
+                FLINK_HOME="$FLINK_HOME_VALUE"
+                echo "[INFO] Set FLINK_HOME to ${FLINK_HOME_VALUE}."
+                break
+            fi
+            ;;
         --flink-home)
             if [[ -n "${args[i+1]}" ]]; then
                 FLINK_HOME="${args[i+1]}"
+                echo "[INFO] Set FLINK_HOME to ${FLINK_HOME}."
                 break
             fi
             ;;