fix

lidezhu · lidezhu · commit 34945e692fe0 · 2026-03-12T16:00:29.000+08:00
diff --git a/logservice/schemastore/persist_storage_ddl_handlers.go b/logservice/schemastore/persist_storage_ddl_handlers.go
@@ -18,6 +18,7 @@ import (
 	"errors"
 	"fmt"
 	"strings"
+	"unicode"
 
 	"github.com/pingcap/log"
 	"github.com/pingcap/ticdc/pkg/common"
@@ -2843,7 +2844,7 @@ func rebuildCreateTablesQueries(query string, tableInfos []*model.TableInfo, sto
 			return nil, cerror.WrapError(cerror.ErrTiDBUnexpectedJobMeta, err)
 		}
 
-		query := queryBuilder.String()
+		query := strings.TrimRightFunc(queryBuilder.String(), unicode.IsSpace)
 		if !strings.HasSuffix(query, ";") {
 			query += ";"
 		}

Original file line number	Diff line number	Diff line change
`@@ -18,6 +18,7 @@ import (`
`18`	`18`	`"errors"`
`19`	`19`	`"fmt"`
`20`	`20`	`"strings"`
	`21`	`+ "unicode"`
`21`	`22`
`22`	`23`	`"github.com/pingcap/log"`
`23`	`24`	`"github.com/pingcap/ticdc/pkg/common"`
`@@ -2843,7 +2844,7 @@ func rebuildCreateTablesQueries(query string, tableInfos []*model.TableInfo, sto`
`2843`	`2844`	`return nil, cerror.WrapError(cerror.ErrTiDBUnexpectedJobMeta, err)`
`2844`	`2845`	`}`
`2845`	`2846`
`2846`		`- query := queryBuilder.String()`
	`2847`	`+ query := strings.TrimRightFunc(queryBuilder.String(), unicode.IsSpace)`
`2847`	`2848`	`if !strings.HasSuffix(query, ";") {`
`2848`	`2849`	`query += ";"`
`2849`	`2850`	`}`