mongodb2tdengine check records count before flush

2021-11-18 19:08:19 +08:00
parent ca1851fb99
commit 75d4f7e101
1 changed files with 5 additions and 1 deletions
@@ -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) {