From 75d4f7e101bc17bf0427acc7efcdafb4648642ff Mon Sep 17 00:00:00 2001
From: dingbo <dingbo8128@163.com>
Date: Thu, 18 Nov 2021 19:08:19 +0800
Subject: [PATCH] mongodb2tdengine check records count before flush

---
 .../datax/plugin/writer/tdenginewriter/JDBCBatchWriter.java | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/tdenginewriter/src/main/java/com/alibaba/datax/plugin/writer/tdenginewriter/JDBCBatchWriter.java b/tdenginewriter/src/main/java/com/alibaba/datax/plugin/writer/tdenginewriter/JDBCBatchWriter.java
index 21974e93..3b1f860b 100644
--- a/tdenginewriter/src/main/java/com/alibaba/datax/plugin/writer/tdenginewriter/JDBCBatchWriter.java
+++ b/tdenginewriter/src/main/java/com/alibaba/datax/plugin/writer/tdenginewriter/JDBCBatchWriter.java
@@ -218,7 +218,11 @@ public class JDBCBatchWriter {
                     break;
                 }
             }
-            initFiledTypesAndTargetTable(records);
+            if (records.size() > 0) {
+                initFiledTypesAndTargetTable(records);
+            } else {
+                return;
+            }
         }
         for (String tabName : buf.keySet()) {
             if (buf.get(tabName).size() > 0) {