diff --git a/pkg/ccr/base/spec.go b/pkg/ccr/base/spec.go index 5624f1a0..0b0150ce 100644 --- 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 (((") {