diff --git a/muyu-source-common/src/main/java/com/muyu/source/pool/MysqlPool.java b/muyu-source-common/src/main/java/com/muyu/source/pool/MysqlPool.java
index da5b5df..d360689 100644
--- a/muyu-source-common/src/main/java/com/muyu/source/pool/MysqlPool.java
+++ b/muyu-source-common/src/main/java/com/muyu/source/pool/MysqlPool.java
@@ -107,9 +107,9 @@ public class MysqlPool implements BasePool<Connection>{
             return mysqlConn;
         }
 
-//        if ((System.currentTimeMillis() - startTime)>this.etlDataScore.getMaxWaitTime()){
-//            throw new MysqlConnException("连接超时!");
-//        }
+        if ((System.currentTimeMillis() - startTime)>this.etlDataScore.getMaxWaitTime()){
+            throw new MysqlConnException("连接超时!");
+        }
 
         return null;
     }
diff --git a/muyu-source-server/src/main/java/com/muyu/source/service/Impl/DataValueServiceImpl.java b/muyu-source-server/src/main/java/com/muyu/source/service/Impl/DataValueServiceImpl.java
index 385f9f1..a38b965 100644
--- a/muyu-source-server/src/main/java/com/muyu/source/service/Impl/DataValueServiceImpl.java
+++ b/muyu-source-server/src/main/java/com/muyu/source/service/Impl/DataValueServiceImpl.java
@@ -37,7 +37,7 @@ public class DataValueServiceImpl extends ServiceImpl<DataValueMapper, DataValue
     // 每批次查询的记录数
     private static final int BATCH_SIZE = 1000;
     // 线程池大小
-    private static final int THREAD_POOL_SIZE = 100;
+    private static final int THREAD_POOL_SIZE = 19;
     @Override
     public List<DataValue> findTableValue(DataValueModel dataValueModel) {
         List<DataValue> dataValueList = new ArrayList<>();