diff --git a/doriswriter/src/main/java/com/alibaba/datax/plugin/writer/doriswriter/DorisJsonCodec.java b/doriswriter/src/main/java/com/alibaba/datax/plugin/writer/doriswriter/DorisJsonCodec.java index 664b9d36..2a68d050 100644 --- a/doriswriter/src/main/java/com/alibaba/datax/plugin/writer/doriswriter/DorisJsonCodec.java +++ b/doriswriter/src/main/java/com/alibaba/datax/plugin/writer/doriswriter/DorisJsonCodec.java @@ -45,6 +45,6 @@ public class DorisJsonCodec extends DorisCodec { rowMap.put(fieldName, this.convertColumn(row.getColumn(idx))); ++idx; } - return JSON.toJSONString(rowMap); + return JSON.toJSONString(rowMap, SerializerFeature.WriteMapNullValue); } }