diff --git a/tdenginewriter/src/main/java/com/alibaba/datax/plugin/writer/tdenginewriter/DefaultDataHandler.java b/tdenginewriter/src/main/java/com/alibaba/datax/plugin/writer/tdenginewriter/DefaultDataHandler.java
index 7854afee..f2d86509 100644
--- a/tdenginewriter/src/main/java/com/alibaba/datax/plugin/writer/tdenginewriter/DefaultDataHandler.java
+++ b/tdenginewriter/src/main/java/com/alibaba/datax/plugin/writer/tdenginewriter/DefaultDataHandler.java
@@ -89,6 +89,7 @@ public class DefaultDataHandler implements DataHandler {
                     recordBatch.add(record);
                 } else {
                     try {
+                        recordBatch.add(record);
                         affectedRows = writeBatch(conn, recordBatch);
                     } catch (SQLException e) {
                         LOG.warn("use one row insert. because:" + e.getMessage());