fix: correct CHANGE REPLICATION FILTER' statement

apecloud · Jan 2, 2025 · b2bc1ab · b2bc1ab
1 parent 24726b2
commit b2bc1ab
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/devtools/replica-setup-mysql/start_replication.sh b/devtools/replica-setup-mysql/start_replication.sh
@@ -26,16 +26,16 @@ fi
 # Prepare replication filters
 REPLICATION_FILTERS=""
 if [ -n "$INCLUDE_SCHEMAS" ]; then
-    REPLICATION_FILTERS="$REPLICATION_FILTERS REPLICATE_DO_DB=(${INCLUDE_SCHEMAS})"
+    REPLICATION_FILTERS="REPLICATE_DO_DB=(${INCLUDE_SCHEMAS})"
 fi
 if [ -n "$EXCLUDE_SCHEMAS" ]; then
-    REPLICATION_FILTERS="$REPLICATION_FILTERS REPLICATE_IGNORE_DB=(${EXCLUDE_SCHEMAS})"
+    REPLICATION_FILTERS="${REPLICATION_FILTERS}${REPLICATION_FILTERS:+, }REPLICATE_IGNORE_DB=(${EXCLUDE_SCHEMAS})"
 fi
 if [ -n "$INCLUDE_TABLES" ]; then
-    REPLICATION_FILTERS="$REPLICATION_FILTERS REPLICATE_DO_TABLE=(${INCLUDE_TABLES})"
+    REPLICATION_FILTERS="${REPLICATION_FILTERS}${REPLICATION_FILTERS:+, }REPLICATE_DO_TABLE=(${INCLUDE_TABLES})"
 fi
 if [ -n "$EXCLUDE_TABLES" ]; then
-    REPLICATION_FILTERS="$REPLICATION_FILTERS REPLICATE_IGNORE_TABLE=(${EXCLUDE_TABLES})"
+    REPLICATION_FILTERS="${REPLICATION_FILTERS}${REPLICATION_FILTERS:+, }REPLICATE_IGNORE_TABLE=(${EXCLUDE_TABLES})"
 fi
 
 # Add filter command if any filters are set