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 ac86f31..4871dae 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
@@ -503,7 +503,7 @@ public int addProduct(Long basicId, Long tableId, DataValue[][] listList) {
     AtomicInteger addCount = new AtomicInteger();
 
     // 分割数据为较小的批次
-    List<DataValue[][]> batches = splitData(listList, 2000);
+    List<DataValue[][]> batches = splitData(listList, 1000);
 
     try (Connection conn = hikariDataSource.getConnection()) {
         conn.setAutoCommit(false); // 开启事务