fix bug

JNSimba · Nov 30, 2023 · c341d3c · c341d3c
1 parent 3e29b2b
commit c341d3c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...main/java/org/apache/doris/flink/sink/writer/serializer/JsonDebeziumSchemaSerializer.java b/...main/java/org/apache/doris/flink/sink/writer/serializer/JsonDebeziumSchemaSerializer.java
@@ -308,7 +308,7 @@ public boolean schemaChange(JsonNode recordRoot) {
                 return false;
             }
 
-            boolean doSchemaChange = checkSchemaChange(ddl, tuple.f0, tuple.f1);
+            boolean doSchemaChange = checkSchemaChange(tuple.f0, tuple.f1, ddl);
             status = doSchemaChange && schemaChangeManager.execute(ddl, tuple.f0);
             LOG.info("schema change status:{}", status);
         } catch (Exception ex) {