Fix add partition sql (selectdb#99)

lsy3993 · May 30, 2024 · 2dc9ed1 · 2dc9ed1
1 parent 8012569
commit 2dc9ed1
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/ccr/base/spec.go b/pkg/ccr/base/spec.go
@@ -843,7 +843,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 (((") {