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

寻找报错

master
Cui YongXing 2024-09-06 00:12:41 +08:00
parent bedcd79ac2
commit efb836ba61
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -329,7 +329,7 @@ public class TaskInfoServiceImpl extends ServiceImpl<TaskInfoMapper, TaskInfo> i
log.info("{}查询结束",sqlSelect); log.info("{}查询结束",sqlSelect);
log.info("执行{}添加的方法",sqlSelect); log.info("执行{}添加的方法",sqlSelect);
Result result = datasourceFeign.addProduct(newBasicId, tableId, data); Result result = datasourceFeign.addProduct(newBasicId, tableId, data);
log.info("{}添加结束",sqlSelect); log.info("{}添加结束",result);
// for (List<DataValue> dataValues : tableValue) { // for (List<DataValue> dataValues : tableValue) {
// for (DataValue dataValue : dataValues) { // for (DataValue dataValue : dataValues) {
// String key = dataValue.getKey(); // String key = dataValue.getKey();

2
cloud-task-server/src/main/java/com/muyu/task/server/thread/OptimizedPrioritizedThreadPool.java
View File

@ -37,7 +37,7 @@ public class OptimizedPrioritizedThreadPool {
// 创建固定大小的线程池 // 创建固定大小的线程池
executor = new ThreadPoolExecutor( executor = new ThreadPoolExecutor(
totalThreads, totalThreads, totalThreads, totalThreads,
60L, TimeUnit.SECONDS, 80L, TimeUnit.SECONDS,
new LinkedBlockingQueue<Runnable>() new LinkedBlockingQueue<Runnable>()
); );
highPrioritySemaphore = new Semaphore(defaultHighThreads); highPrioritySemaphore = new Semaphore(defaultHighThreads);