From c35d3e18f224f78bb857d5a11a8136e9675db74f Mon Sep 17 00:00:00 2001 From: conghe2402 Date: Mon, 21 Nov 2022 18:30:32 +0800 Subject: [PATCH] [hotfix][hdfs]when writing to hdfs, null value is set to '\N' [hotfix][hdfs]when writing to hdfs, null value is set to '\N' for hive specification so that hdfs connector can read from the output [hotfix][hdfs]when writing to hdfs, null value is set to '\N' for hive specification so that hdfs connector can read from the output --- .../connector/hdfs/converter/HdfsTextColumnConverter.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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); }