@@ -707,8 +707,8 @@ public class SeSnapshotServiceImpl implements SeSnapshotService {
int inserted = 0;
if (!toInsert.isEmpty()) {
inserted = insertBatchSharded(rows -> {
- toInsert.forEach(segmentPquiMapper::insert);
- return toInsert.size();
+ rows.forEach(segmentPquiMapper::insert);
+ return rows.size();
}, toInsert);
}
log.info("段PQUI明细入库完成 snapTime={}, 写入{}条, 跳过{}条(无数据{}条/重复{}条)",