diff --git a/chunjun-connectors/chunjun-connector-hdfs/src/main/java/com/dtstack/chunjun/connector/hdfs/converter/HdfsTextColumnConverter.java b/chunjun-connectors/chunjun-connector-hdfs/src/main/java/com/dtstack/chunjun/connector/hdfs/converter/HdfsTextColumnConverter.java index 07717c71a4..121bd87f26 100644 --- a/chunjun-connectors/chunjun-connector-hdfs/src/main/java/com/dtstack/chunjun/connector/hdfs/converter/HdfsTextColumnConverter.java +++ b/chunjun-connectors/chunjun-connector-hdfs/src/main/java/com/dtstack/chunjun/connector/hdfs/converter/HdfsTextColumnConverter.java @@ -130,7 +130,7 @@ protected ISerializationConverter wrapIntoNullableExternalConverter( ISerializationConverter serializationConverter, String type) { return (rowData, index, data) -> { if (rowData == null || rowData.isNullAt(index)) { - data[index] = null; + data[index] = "\\N"; } else { serializationConverter.serialize(rowData, index, data); }