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");
                         }