schemastore: ignore system schema (#1009)

pingcap · Feb 18, 2025 · 60a2dbb · 60a2dbb
1 parent bbd60cd
commit 60a2dbb
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/logservice/schemastore/schema_store.go b/logservice/schemastore/schema_store.go
@@ -322,8 +322,7 @@ func (s *schemaStore) writeDDLEvent(ddlEvent DDLJobWithCommitTs) {
 		zap.Uint64("finishedTs", ddlEvent.Job.BinlogInfo.FinishedTS),
 		zap.String("query", ddlEvent.Job.Query))
 
-	// TODO: find a better way to filter out system tables
-	if ddlEvent.Job.SchemaID != 1 {
+	if !filter.IsSysSchema(ddlEvent.Job.SchemaName) {
 		s.unsortedCache.addDDLEvent(ddlEvent)
 	}
 }