From 100fb4a59ebf581a46cb65505d95410fccfa0284 Mon Sep 17 00:00:00 2001
From: Qingsheng Ren <renqschn@gmail.com>
Date: Sat, 2 Dec 2023 10:28:17 +0800
Subject: [PATCH] [cdc-dist] Introduce flink-cdc.sh as the entrypoint of the
 Flink CDC (#2791)

---
 .../src/main/flink-cdc-bin/bin/flink-cdc.sh   | 50 +++++++++++++++++++
 1 file changed, 50 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 f7772ce95..c4bdedf62 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
@@ -15,4 +15,54 @@
 # limitations under the License.
 ################################################################################
 
+# Setup FLINK_HOME
+args=("$@")
+# Loop through command-line arguments
+for ((i=0; i < ${#args[@]}; i++)); do
+    case "${args[i]}" in
+        --flink-home)
+            if [[ -n "${args[i+1]}" ]]; then
+                FLINK_HOME="${args[i+1]}"
+                break
+            fi
+            ;;
+    esac
+done
 
+# Define directories
+SCRIPT_DIR=$( cd -- "$( dirname -- "${BASH_SOURCE[0]}" )" &> /dev/null && pwd )
+FLINK_CDC_HOME="$SCRIPT_DIR"/..
+FLINK_CDC_CONF="$FLINK_CDC_HOME"/conf
+FLINK_CDC_LIB="$FLINK_CDC_HOME"/lib
+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
+  CLASSPATH=$CLASSPATH:$jar
+done
+# Add Flink CDC libraries to classpath
+for jar in "$FLINK_CDC_LIB"/*.jar; do
+  CLASSPATH=$CLASSPATH:$jar
+done
+# Trim classpath
+CLASSPATH=${CLASSPATH#:}
+
+# Setup Java by operating system
+UNAME=$(uname -s)
+if [ "${UNAME:0:6}" == "CYGWIN" ]; then
+    JAVA_RUN=java
+else
+    if [[ -d "$JAVA_HOME" ]]; then
+        JAVA_RUN="$JAVA_HOME"/bin/java
+    else
+        JAVA_RUN=java
+    fi
+fi
+
+# Setup logging
+LOG=$FLINK_CDC_LOG/flink-cdc-cli-$HOSTNAME.log
+LOG_SETTINGS=(-Dlog.file="$LOG" -Dlog4j.configuration=file:"$FLINK_CDC_CONF"/log4j-cli.properties -Dlog4j.configurationFile=file:"$FLINK_CDC_CONF"/log4j-cli.properties)
+
+exec "$JAVA_RUN" -classpath "$CLASSPATH" "${LOG_SETTINGS[@]}" com.ververica.cdc.cli.CliFrontend "$@"