From 8b76c5a3386501e4b23e6f19d54ccc0c494ef92c Mon Sep 17 00:00:00 2001 From: wk989898 Date: Mon, 27 Jan 2025 15:01:18 +0800 Subject: [PATCH] . --- logservice/schemastore/persist_storage_ddl_handlers.go | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/logservice/schemastore/persist_storage_ddl_handlers.go b/logservice/schemastore/persist_storage_ddl_handlers.go index 730104db..44eb3b0c 100644 --- a/logservice/schemastore/persist_storage_ddl_handlers.go +++ b/logservice/schemastore/persist_storage_ddl_handlers.go @@ -20,7 +20,6 @@ import ( "github.com/pingcap/log" "github.com/pingcap/ticdc/heartbeatpb" "github.com/pingcap/ticdc/pkg/common" - "github.com/pingcap/ticdc/pkg/common/event" commonEvent "github.com/pingcap/ticdc/pkg/common/event" "github.com/pingcap/ticdc/pkg/filter" "github.com/pingcap/tidb/pkg/meta/model" @@ -1907,7 +1906,7 @@ func buildDDLEventForRenameTables(rawEvent *PersistedDDLEvent, tableFilter filte InfluenceType: commonEvent.InfluenceTypeNormal, TableIDs: []int64{heartbeatpb.DDLSpan.TableID}, } - querys, err := event.SplitQueries(rawEvent.Query) + querys, err := commonEvent.SplitQueries(rawEvent.Query) if err != nil { log.Panic("split queries failed", zap.Error(err)) } @@ -2041,7 +2040,7 @@ func buildDDLEventForCreateTables(rawEvent *PersistedDDLEvent, tableFilter filte if allFiltered { return commonEvent.DDLEvent{}, false } - querys, err := event.SplitQueries(rawEvent.Query) + querys, err := commonEvent.SplitQueries(rawEvent.Query) if err != nil { log.Panic("split queries failed", zap.Error(err)) }