Fix for mysql source being restarted after new table added

MaterializeInc · Oct 29, 2024 · 9f4276f · 9f4276f
1 parent cade5df
commit 9f4276f
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/src/storage/src/source/mysql/replication/events.rs b/src/storage/src/source/mysql/replication/events.rs
@@ -197,6 +197,11 @@ pub(super) async fn handle_query_event(
         (Some("commit"), None) => {
             is_complete_event = true;
         }
+        // Detect `CREATE TABLE <tbl>` statements which don't affect existing tables but do
+        // signify a complete event (e.g. for the purposes of advancing the GTID)
+        (Some("create"), Some("table")) => {
+            is_complete_event = true;
+        }
         _ => {}
     }