From adfb2581d3d04b29de6c88ab329804b6aee021e0 Mon Sep 17 00:00:00 2001
From: fariel <hf@dorisdb.com>
Date: Fri, 12 Mar 2021 18:53:07 +0800
Subject: [PATCH] fix null data convertion

---
 .../connector/datax/plugin/writer/doriswriter/DorisWriter.java | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/doriswriter/src/main/java/com/dorisdb/connector/datax/plugin/writer/doriswriter/DorisWriter.java b/doriswriter/src/main/java/com/dorisdb/connector/datax/plugin/writer/doriswriter/DorisWriter.java
index 0cbe579c..05cef7a4 100755
--- a/doriswriter/src/main/java/com/dorisdb/connector/datax/plugin/writer/doriswriter/DorisWriter.java
+++ b/doriswriter/src/main/java/com/dorisdb/connector/datax/plugin/writer/doriswriter/DorisWriter.java
@@ -112,7 +112,8 @@ public class DorisWriter extends Writer {
                     }
                     StringBuilder sb = new StringBuilder();
                     for (int i = 0; i < record.getColumnNumber(); i++) {
-                        sb.append(record.getColumn(i).getRawData().toString());
+                        Object value = record.getColumn(i).getRawData();
+                        sb.append(null == value ? "\\N" : value);
                         if (i < record.getColumnNumber() - 1) {
                             sb.append("\t");
                         }