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: timeout bug #678

Browse Source
This commit is contained in:
tjq 2023-08-13 21:30:58 +08:00
parent 89b35c8495
commit c08b4f1858
2 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
powerjob-official-processors/src/main/java/tech/powerjob/official/processors/impl/VerificationProcessor.java
View File

@ -76,7 +76,10 @@ public class VerificationProcessor extends CommonBasicProcessor implements MapRe
} }
} }
return new ProcessResult(true, "EXECUTE_SUCCESSFULLY_" + RandomStringUtils.randomAlphanumeric(Optional.ofNullable(verificationParam.getResponseSize()).orElse(10)));
String randomMsg = RandomStringUtils.randomAlphanumeric(Optional.ofNullable(verificationParam.getResponseSize()).orElse(10));
omsLogger.info("generate random string: {}", randomMsg);
return new ProcessResult(true, "EXECUTE_SUCCESSFULLY_" + randomMsg);
} }
@Override @Override
@ -87,6 +90,7 @@ public class VerificationProcessor extends CommonBasicProcessor implements MapRe
enum Mode { enum Mode {
/** /**
* 常规模式，直接返回响应 * 常规模式，直接返回响应
* {"mode":"BASE","responseSize":12}
*/ */
BASE, BASE,
/** /**

1
powerjob-worker/src/main/java/tech/powerjob/worker/core/tracker/task/TaskTracker.java
View File

@ -73,6 +73,7 @@ public abstract class TaskTracker {
instanceInfo.setThreadConcurrency(req.getThreadConcurrency()); instanceInfo.setThreadConcurrency(req.getThreadConcurrency());
instanceInfo.setTaskRetryNum(req.getTaskRetryNum()); instanceInfo.setTaskRetryNum(req.getTaskRetryNum());
instanceInfo.setLogConfig(req.getLogConfig()); instanceInfo.setLogConfig(req.getLogConfig());
instanceInfo.setInstanceTimeoutMS(req.getInstanceTimeoutMS());
// 特殊处理超时时间 // 特殊处理超时时间
if (instanceInfo.getInstanceTimeoutMS() <= 0) { if (instanceInfo.getInstanceTimeoutMS() <= 0) {