From 19f1e3d755bc14b9ad90efa58fda95a563d8c077 Mon Sep 17 00:00:00 2001
From: Robin Tang <rtang.cs@gmail.com>
Date: Fri, 20 Dec 2024 11:03:44 -0800
Subject: [PATCH] Update.

---
 sources/mysql/streaming/ddl/ddl.go | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/sources/mysql/streaming/ddl/ddl.go b/sources/mysql/streaming/ddl/ddl.go
index eac09189..61bc6d7a 100644
--- a/sources/mysql/streaming/ddl/ddl.go
+++ b/sources/mysql/streaming/ddl/ddl.go
@@ -108,7 +108,8 @@ func (s *SchemaAdapter) applyDDL(unixTs int64, result antlr.Event) error {
 
 	tblAdapter, ok := s.adapters[result.GetTable()]
 	if !ok {
-		return fmt.Errorf("table not found: %q", result.GetTable())
+		return nil
+		//return fmt.Errorf("table not found: %q", result.GetTable())
 	}
 
 	switch castedResult := result.(type) {