diff --git a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/format/RecordParser.java b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/format/RecordParser.java
index 4dcbb2a81c95..1d76fd91f9cc 100644
--- a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/format/RecordParser.java
+++ b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/format/RecordParser.java
@@ -158,7 +158,7 @@ protected Map<String, String> extractRowData(
                                                     return Objects.toString(entry.getValue());
                                                 }
                                             }
-                                            return Objects.toString(entry.getValue());
+                                            return Objects.toString(entry.getValue(), "");
                                         }));
         evalComputedColumns(rowData, paimonFieldTypes);
         return rowData;