Add test for resume with overwrite checkpointTs

tests/integration_tests/overwrite_resume_with_syncpoint/conf/changefeed.toml

@@ -0,0 +1,2 @@
+enable-sync-point = true
+sync-point-interval = "30s"

tests/integration_tests/overwrite_resume_with_syncpoint/run.sh

@@ -0,0 +1,67 @@
+#!/bin/bash
+# the script test when we enable syncpoint, and pause the changefeed,
+# then resume with a forward checkpoint, to ensure the changefeed can be sync correctly.
+
+set -eux
+
+CUR=$(cd "$(dirname "${BASH_SOURCE[0]}")" && pwd)
+source $CUR/../_utils/test_prepare
+WORK_DIR=$OUT_DIR/$TEST_NAME
+CDC_BINARY=cdc.test
+SINK_TYPE=$1
+
+function check_ts_forward() {
+	changefeedid=$1
+	rts1=$(cdc cli changefeed query --changefeed-id=${changefeedid} 2>&1 | jq '.resolved_ts')
+	checkpoint1=$(cdc cli changefeed query --changefeed-id=${changefeedid} 2>&1 | jq '.checkpoint_tso')
+	sleep 1
+	rts2=$(cdc cli changefeed query --changefeed-id=${changefeedid} 2>&1 | jq '.resolved_ts')
+	checkpoint2=$(cdc cli changefeed query --changefeed-id=${changefeedid} 2>&1 | jq '.checkpoint_tso')
+	if [[ "$rts1" != "null" ]] && [[ "$rts1" != "0" ]]; then
+		if [[ "$rts1" -ne "$rts2" ]] || [[ "$checkpoint1" -ne "$checkpoint2" ]]; then
+			echo "changefeed is working normally rts: ${rts1}->${rts2} checkpoint: ${checkpoint1}->${checkpoint2}"
+			return
+		fi
+	fi
+	exit 1
+}
+
+function run() {
+	# No need to test kafka and storage sink.
+	if [ "$SINK_TYPE" != "mysql" ]; then
+		return
+	fi
+
+	rm -rf $WORK_DIR && mkdir -p $WORK_DIR
+
+	start_tidb_cluster --workdir $WORK_DIR
+
+	cd $WORK_DIR
+
+	run_cdc_server --workdir $WORK_DIR --binary $CDC_BINARY
+
+	SINK_URI="mysql://[email protected]:3306/"
+	run_cdc_cli changefeed create --sink-uri="$SINK_URI" --config=$CUR/conf/changefeed.toml --changefeed-id="test4"
+
+	check_ts_forward "test4"
+
+	run_cdc_cli changefeed pause --changefeed-id="test4"
+
+	sleep 15
+
+	checkpoint1=$(cdc cli changefeed query --changefeed-id="test4" 2>&1 | jq '.checkpoint_tso')
+	# add a large number to avoid the problem of losing precision when jq processing large integers
+	checkpoint1=$((checkpoint1 + 1000000))
+
+	# resume a forward checkpointTs
+	run_cdc_cli changefeed resume --changefeed-id="test4" --no-confirm --overwrite-checkpoint-ts=$checkpoint1
+
+	check_ts_forward "test4"
+
+	cleanup_process $CDC_BINARY
+}
+
+trap stop_tidb_cluster EXIT
+run $*
+check_logs $WORK_DIR
+echo "[$(date)] <<<<<< run test case $TEST_NAME success! >>>>>>"

tests/integration_tests/run_group.sh

@@ -52,7 +52,7 @@ groups=(
 	# G09
 	'gc_safepoint changefeed_pause_resume cli_with_auth savepoint synced_status'
 	# G10
-	'default_value simple cdc_server_tips event_filter sql_mode'
+	'default_value simple cdc_server_tips event_filter sql_mode overwrite_resume_with_syncpoint'
 	# G11
 	'resolve_lock move_table autorandom generate_column'
 	# G12