From dad209feb81ce7898dcf56c25012ba89770241a8 Mon Sep 17 00:00:00 2001
From: "jianghang.loujh" <jianghang.loujh@alibaba-inc.com>
Date: Fri, 16 May 2025 14:57:54 +0800
Subject: [PATCH] fixed issue #5453 , skipping Query_log_event by unknown
 status vars

---
 .../com/taobao/tddl/dbsync/binlog/event/QueryLogEvent.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/QueryLogEvent.java b/dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/QueryLogEvent.java
index 991593dc..8bbb8a42 100644
--- a/dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/QueryLogEvent.java
+++ b/dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/QueryLogEvent.java
@@ -773,7 +773,7 @@ public class QueryLogEvent extends LogEvent {
                             // percona
                             // *start++ = thd->variables.binlog_ddl_skip_rewrite;
                             buffer.forward(1);
-                        }else {
+                        } else {
                             // PolarDB-X
                             // *start++ = thd->variables.opt_flashback_area;
                             buffer.forward(1);
@@ -835,7 +835,7 @@ public class QueryLogEvent extends LogEvent {
                          */
                         logger.error("Query_log_event has unknown status vars (first has code: " + code
                                      + "), skipping the rest of them");
-                        break; // Break loop
+                        return; // Break loop
                 }
             }
         } catch (RuntimeException e) {