Fix add partition case (selectdb#98)

lsy3993 · Jun 7, 2024 · ef55d35 · ef55d35
1 parent e6e0ee9
commit ef55d35
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/pkg/ccr/base/spec.go b/pkg/ccr/base/spec.go
@@ -835,7 +835,7 @@ func correctAddPartitionSql(addPartitionSql string, addPartition *record.AddPart
 	// 1. fix unpartitioned add partition sql
 	// 2. support add temporary partition
 	if strings.Contains(addPartitionSql, "VALUES [(), ())") {
-		re := regexp.MustCompile(`VALUES \[\(\), \(\)\) \(.*\)`)
+		re := regexp.MustCompile(`VALUES \[\(\), \(\)\) \(.*^\)\)`)
 		addPartitionSql = re.ReplaceAllString(addPartitionSql, "")
 	}
 	if strings.Contains(addPartitionSql, "VALUES IN (((") {

diff --git a/regression-test/suites/table-sync/test_add_partition.groovy b/regression-test/suites/table-sync/test_add_partition.groovy
@@ -262,7 +262,7 @@ suite("test_add_partition") {
     assertTrue(checkRestoreFinishTimesOf("${tableName}", 60))
 
     sql """
-        INSERT OVERWRITE ${tableName} VALUES (1, 100);
+        INSERT OVERWRITE TABLE ${tableName} VALUES (1, 100);
        """
 
     assertTrue(checkShowTimesOf("""