修复了上述问题

This commit is contained in:
sanChouIsACat 2021-12-30 11:09:58 +08:00
parent c96a366a4e
commit c140ca35fb

View File

@ -326,14 +326,13 @@ public class ConcurrentTableWriterTask extends CommonRdbmsWriter.Task {
} }
groupValues.add(record); groupValues.add(record);
if (groupValues.size() >= batchSize) { if (groupValues.size() >= batchSize) {
int i = 0;
groupValues = addRecordsToWriteQueue(groupValues); groupValues = addRecordsToWriteQueue(groupValues);
groupInsertValues.put(partId, groupValues); groupInsertValues.put(partId, groupValues);
} }
} else { } else {
LOG.debug("add unknown part record {}", record); LOG.debug("add unknown part record {}", record);
unknownPartRecords.add(record); unknownPartRecords.add(record);
if (unknownPartRecords.size() > batchSize) { if (unknownPartRecords.size() >= batchSize) {
unknownPartRecords = addRecordsToWriteQueue(unknownPartRecords); unknownPartRecords = addRecordsToWriteQueue(unknownPartRecords);
} }