Update UpdatedDataFieldsProcessFunctionBase.java

apache · Nov 21, 2024 · 53b598e · 53b598e
1 parent 77b2522
commit 53b598e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/.../src/main/java/org/apache/paimon/flink/sink/cdc/UpdatedDataFieldsProcessFunctionBase.java b/.../src/main/java/org/apache/paimon/flink/sink/cdc/UpdatedDataFieldsProcessFunctionBase.java
@@ -97,7 +97,7 @@ protected void applySchemaChange(
                             e);
                 }
             }
-            //        } else if (schemaChange instanceof SchemaChange.UpdateColumnType) {
+        } else if (schemaChange instanceof SchemaChange.UpdateColumnType) {
             SchemaChange.UpdateColumnType updateColumnType =
                     (SchemaChange.UpdateColumnType) schemaChange;
             Preconditions.checkState(