From 53b598e567ccb9ef44faacc95a7f3048970f851d Mon Sep 17 00:00:00 2001 From: JackeyLee007 Date: Thu, 21 Nov 2024 17:00:51 +0800 Subject: [PATCH] Update UpdatedDataFieldsProcessFunctionBase.java --- .../flink/sink/cdc/UpdatedDataFieldsProcessFunctionBase.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/sink/cdc/UpdatedDataFieldsProcessFunctionBase.java b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/sink/cdc/UpdatedDataFieldsProcessFunctionBase.java index 36542ae8f641f..c2e928bd4a0aa 100644 --- a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/sink/cdc/UpdatedDataFieldsProcessFunctionBase.java +++ b/paimon-flink/paimon-flink-cdc/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(