From 0ac81e1b404185cd2667811713e7936c87452767 Mon Sep 17 00:00:00 2001
From: conghe2402 <haohaohao2004@qq.com>
Date: Tue, 22 Nov 2022 11:57:17 +0800
Subject: [PATCH] [hotfix][hdfs]when writing to hdfs, null value is set to '\N'
 (#1408)

[hotfix][hdfs]when writing to hdfs, null value is set to '\N' for hive specification so that hdfs connector can read from the output

(cherry picked from commit a924b98866be0cb985b80d6b77de18aabdb5d093)
---
 .../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<String[]> 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);
             }