third_codes/PowerJob
1
0
Fork 1
mirror of https://github.com/PowerJob/PowerJob.git synced 2025-07-17 00:00:04 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: Server scheduling exception when worker is overloaded #853

Browse Source
This commit is contained in:
tjq 2024-03-01 22:06:51 +08:00
parent 9d95d4ce04
commit 9046a8bfcf
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
powerjob-server/powerjob-server-core/src/main/java/tech/powerjob/server/core/scheduler/InstanceStatusCheckService.java
View File

@ -145,7 +145,11 @@ public class InstanceStatusCheckService {
log.info("[InstanceStatusChecker] RunningInstance status check using {}.", stopwatch.stop()); log.info("[InstanceStatusChecker] RunningInstance status check using {}.", stopwatch.stop());
} }
private void handleWaitingDispatchInstance(List<Long> partAppIds) { private void handleWaitingDispatchInstance(List<Long> appIds) {
// 存在移除操作，需要重新创建集合，否则会导致外层抛出 NoSuchElementException: null
List<Long> partAppIds = Lists.newArrayList(appIds);
// 1. 检查等待 WAITING_DISPATCH 状态的任务 // 1. 检查等待 WAITING_DISPATCH 状态的任务
long threshold = System.currentTimeMillis() - DISPATCH_TIMEOUT_MS; long threshold = System.currentTimeMillis() - DISPATCH_TIMEOUT_MS;
List<InstanceInfoDO> waitingDispatchInstances = instanceInfoRepository.findAllByAppIdInAndStatusAndExpectedTriggerTimeLessThan(partAppIds, InstanceStatus.WAITING_DISPATCH.getV(), threshold, PageRequest.of(0, MAX_BATCH_NUM_INSTANCE)); List<InstanceInfoDO> waitingDispatchInstances = instanceInfoRepository.findAllByAppIdInAndStatusAndExpectedTriggerTimeLessThan(partAppIds, InstanceStatus.WAITING_DISPATCH.getV(), threshold, PageRequest.of(0, MAX_BATCH_NUM_INSTANCE));