TreeData
/
cloud-etl-task
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

测试线程池

master
陈思豪 2024-09-10 09:54:23 +08:00
parent 30a4440030
commit 15737e4452
2 changed files with 12 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
cloud-task-common/pom.xml
View File

@ -30,11 +30,17 @@
<version>1.0.0</version> <version>1.0.0</version>
</dependency> </dependency>
<!-- <dependency>--> <dependency>
<!-- <groupId>com.muyu</groupId>--> <groupId>com.muyu</groupId>
<!-- <artifactId>cloud-etl-client</artifactId>--> <artifactId>cloud-etl-common</artifactId>
<!-- <version>1.0.0</version>--> <version>1.0.0</version>
<!-- </dependency>--> </dependency>
<dependency>
<groupId>com.muyu</groupId>
<artifactId>cloud-etl-common</artifactId>
<version>1.0.1</version>
</dependency>
</dependencies> </dependencies>

2
cloud-task-server/src/main/java/com/muyu/service/impl/TaskServiceImpl.java
View File

@ -194,7 +194,7 @@ public class TaskServiceImpl extends ServiceImpl<TaskMapper, TaskInfo> implement
log.info("开始查询！！！！！！！！！！！！！！！"); log.info("开始查询！！！！！！！！！！！！！！！");
Integer count = dataValueClient.findCount(Long.valueOf(taskOutputInfo.getBasicId()), sqlCount); Integer count = dataValueClient.findCount(Long.valueOf(taskOutputInfo.getBasicId()), sqlCount);
log.info("查询到的条数为{}", count); log.info("查询到的条数为{}", count);
int pageSize = 20000; int pageSize = 10000;
int totalSegments = (int) Math.ceil((double) count / pageSize); int totalSegments = (int) Math.ceil((double) count / pageSize);
log.info("总共页码为{}", totalSegments); log.info("总共页码为{}", totalSegments);
//查询数据 //查询数据