diff --git a/seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/serialize/SeaTunnelRowSerializer.java b/seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/serialize/SeaTunnelRowSerializer.java
index 0e67257a32e..c984580f8e1 100644
--- a/seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/serialize/SeaTunnelRowSerializer.java
+++ b/seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/serialize/SeaTunnelRowSerializer.java
@@ -70,7 +70,7 @@ public SeaTunnelRowSerializer(
 
         if (JSON.equals(type)) {
             JsonSerializationSchema jsonSerializationSchema =
-                    new JsonSerializationSchema(this.seaTunnelRowType, NULL_VALUE);
+                    new JsonSerializationSchema(this.seaTunnelRowType);
             ObjectMapper mapper = jsonSerializationSchema.getMapper();
             mapper.configure(JsonGenerator.Feature.WRITE_BIGDECIMAL_AS_PLAIN, true);
             this.serialize = jsonSerializationSchema;
diff --git a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-doris-e2e/src/test/java/org/apache/seatunnel/e2e/connector/doris/DorisIT.java b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-doris-e2e/src/test/java/org/apache/seatunnel/e2e/connector/doris/DorisIT.java
index 03ca3ab516d..6b7a3a7f487 100644
--- a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-doris-e2e/src/test/java/org/apache/seatunnel/e2e/connector/doris/DorisIT.java
+++ b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-doris-e2e/src/test/java/org/apache/seatunnel/e2e/connector/doris/DorisIT.java
@@ -535,8 +535,14 @@ protected void batchInsertUniqueTableData() {
             try (PreparedStatement preparedStatement =
                     conn.prepareStatement(INIT_UNIQUE_TABLE_DATA_SQL)) {
                 for (int i = 0; i < rows.size(); i++) {
-                    for (int index = 0; index < rows.get(i).getFields().length; index++) {
-                        preparedStatement.setObject(index + 1, rows.get(i).getFields()[index]);
+                    if (i % 10 == 0) {
+                        for (int index = 0; index < rows.get(i).getFields().length; index++) {
+                            preparedStatement.setObject(index + 1, null);
+                        }
+                    } else {
+                        for (int index = 0; index < rows.get(i).getFields().length; index++) {
+                            preparedStatement.setObject(index + 1, rows.get(i).getFields()[index]);
+                        }
                     }
                     preparedStatement.addBatch();
                 }