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 9580829..fcb345b 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
@@ -40,8 +40,7 @@ public class ProductServiceImpl implements ProductService {
 //        HikariDataSource hikariDataSource = getHikariDataSource(dataSources);
 
         HikariDataSource hikariDataSource = HikariPool.getHikariDataSource(dataSources);
-
-        ExecutorService executorService = Executors.newFixedThreadPool(4);
+        ExecutorService executorService = Executors.newFixedThreadPool(8);
 
         AtomicInteger addCount = new AtomicInteger();