From 22c4f8cd18419a9c0cec9432fea3898c14104d37 Mon Sep 17 00:00:00 2001
From: zyyang <zyyang@taosdata.com>
Date: Tue, 22 Mar 2022 13:50:43 +0800
Subject: [PATCH] [TS-1342]<fix>: record missing when batchWrite

---
 .../datax/plugin/writer/tdenginewriter/DefaultDataHandler.java   | 1 +
 1 file changed, 1 insertion(+)

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());