delete: default normaliztion

suhwan-cheon · suhwan-cheon · commit c8e6b35ef720 · 2026-03-09T13:22:52.000+09:00
diff --git a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/utils/IcebergTypeUtils.java b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/utils/IcebergTypeUtils.java
@@ -72,7 +72,6 @@ public static Literal<?> parseDefaultValue(
         if (defaultValueExpression == null) {
             return null;
         }
-        defaultValueExpression = defaultValueExpression.trim();
         try {
             switch (cdcType.getTypeRoot()) {
                 case CHAR:

Original file line number	Diff line number	Diff line change
`@@ -72,7 +72,6 @@ public static Literal<?> parseDefaultValue(`
`72`	`72`	`if (defaultValueExpression == null) {`
`73`	`73`	`return null;`
`74`	`74`	`}`
`75`		`- defaultValueExpression = defaultValueExpression.trim();`
`76`	`75`	`try {`
`77`	`76`	`switch (cdcType.getTypeRoot()) {`
`78`	`77`	`case CHAR:`