[TS-1342]<fix>: record missing when batchWrite

This commit is contained in:
zyyang 2022-03-22 13:50:43 +08:00
parent 81b004fbb4
commit 22c4f8cd18

View File

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