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

寻找报错

master
Cui YongXing 2024-09-05 23:57:56 +08:00
parent 6fcbb39531
commit 0116c52990
2 changed files with 1 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -324,9 +324,6 @@ public class TaskInfoServiceImpl extends ServiceImpl<TaskInfoMapper, TaskInfo> i
String key = dataValue.getKey(); String key = dataValue.getKey();
String newKey = map.get(key); String newKey = map.get(key);
dataValue.setKey(newKey); dataValue.setKey(newKey);
if (pageNum==160000){
log.info(dataValue);
}
} }
} }
log.info("{}查询结束",sqlSelect); log.info("{}查询结束",sqlSelect);

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

@ -62,7 +62,7 @@ public class OptimizedPrioritizedThreadPool {
emergencySemaphore.release(); emergencySemaphore.release();
if (remainingTasks.decrementAndGet() == 0) { if (remainingTasks.decrementAndGet() == 0) {
try { try {
Thread.sleep(10000); Thread.sleep(800000);
} catch (InterruptedException e) { } catch (InterruptedException e) {
throw new RuntimeException(e); throw new RuntimeException(e);
} }