From 60a2dbb19e861e64b7d954dfb47881961f70e753 Mon Sep 17 00:00:00 2001
From: lidezhu <47731263+lidezhu@users.noreply.github.com>
Date: Tue, 18 Feb 2025 11:44:15 +0800
Subject: [PATCH] schemastore: ignore system schema (#1009)

---
 logservice/schemastore/schema_store.go | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/logservice/schemastore/schema_store.go b/logservice/schemastore/schema_store.go
index 832ff3371..c59365672 100644
--- 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)
 	}
 }