diff --git a/cloud-etl-server/src/main/java/com/muyu/cloud/etl/service/impl/ProductServiceImpl.java b/cloud-etl-server/src/main/java/com/muyu/cloud/etl/service/impl/ProductServiceImpl.java index fd448cb..8f4e52d 100644 --- a/cloud-etl-server/src/main/java/com/muyu/cloud/etl/service/impl/ProductServiceImpl.java +++ b/cloud-etl-server/src/main/java/com/muyu/cloud/etl/service/impl/ProductServiceImpl.java @@ -186,7 +186,7 @@ public class ProductServiceImpl implements ProductService { AtomicInteger addCount = new AtomicInteger(); // 分割数据为3000个批次 - List batches = splitData(listList, 5000); + List batches = splitData(listList, 300); try (Connection conn = hikariDataSource.getConnection()) { conn.setAutoCommit(false); // 开启事务