(fluss) branch main updated: [client] Skipping stale schema change event. (#3028)

[hongshun]

This is an automated email from the ASF dual-hosted git repository.

hongshun pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/fluss.git


The following commit(s) were added to refs/heads/main by this push:
     new 520ce89ba [client] Skipping stale schema change event. (#3028)
520ce89ba is described below

commit 520ce89baf18dfb1bfa095591e3627fcdf80fe90
Author: Hongshun Wang <125648852+loserwang1...@users.noreply.github.com>
AuthorDate: Wed Apr 8 19:43:42 2026 +0800

    [client] Skipping stale schema change event. (#3028)
---
 .../fluss/server/coordinator/CoordinatorEventProcessor.java       | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

diff --git 
a/fluss-server/src/main/java/org/apache/fluss/server/coordinator/CoordinatorEventProcessor.java
 
b/fluss-server/src/main/java/org/apache/fluss/server/coordinator/CoordinatorEventProcessor.java
index 7223c0f01..4f53ba666 100644
--- 
a/fluss-server/src/main/java/org/apache/fluss/server/coordinator/CoordinatorEventProcessor.java
+++ 
b/fluss-server/src/main/java/org/apache/fluss/server/coordinator/CoordinatorEventProcessor.java
@@ -716,7 +716,13 @@ public class CoordinatorEventProcessor implements 
EventProcessor {
         }
 
         TableInfo oldTableInfo = coordinatorContext.getTableInfoById(tableId);
-        if (oldTableInfo.getSchemaId() == schemaInfo.getSchemaId()) {
+        if (oldTableInfo.getSchemaId() >= schemaInfo.getSchemaId()) {
+            LOG.info(
+                    "Skipping stale schema change event for table {} with 
schemaId {}"
+                            + " since the current schemaId is already {}.",
+                    tablePath,
+                    schemaInfo.getSchemaId(),
+                    oldTableInfo.getSchemaId());
             return;
         }