fix: column default value map getter

Signed-off-by: yuxiqian <[email protected]>
apache · Sep 20, 2024 · b9d36c7 · b9d36c7
1 parent d1ff6f0
commit b9d36c7
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/...-doris/src/main/java/org/apache/flink/cdc/connectors/doris/sink/DorisMetadataApplier.java b/...-doris/src/main/java/org/apache/flink/cdc/connectors/doris/sink/DorisMetadataApplier.java
@@ -268,8 +268,7 @@ private void applyAlterColumnTypeEvent(AlterColumnTypeEvent event)
                         new FieldSchema(
                                 entry.getKey(),
                                 buildTypeString(entry.getValue()),
-                                columnDefaultValueMapping.get(
-                                        columnDefaultValueMapping.get(entry.getKey())),
+                                columnDefaultValueMapping.get(entry.getKey()),
                                 null));
             }
         } catch (Exception e) {