diff --git a/powerjob-official-processors/src/main/java/tech/powerjob/official/processors/impl/VerificationProcessor.java b/powerjob-official-processors/src/main/java/tech/powerjob/official/processors/impl/VerificationProcessor.java index 394908d4..9a882dc0 100644 --- a/powerjob-official-processors/src/main/java/tech/powerjob/official/processors/impl/VerificationProcessor.java +++ b/powerjob-official-processors/src/main/java/tech/powerjob/official/processors/impl/VerificationProcessor.java @@ -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 @@ -87,6 +90,7 @@ public class VerificationProcessor extends CommonBasicProcessor implements MapRe enum Mode { /** * 常规模式,直接返回响应 + * {"mode":"BASE","responseSize":12} */ BASE, /** diff --git a/powerjob-worker/src/main/java/tech/powerjob/worker/core/tracker/task/TaskTracker.java b/powerjob-worker/src/main/java/tech/powerjob/worker/core/tracker/task/TaskTracker.java index a1edebc4..58a6bc3a 100644 --- a/powerjob-worker/src/main/java/tech/powerjob/worker/core/tracker/task/TaskTracker.java +++ b/powerjob-worker/src/main/java/tech/powerjob/worker/core/tracker/task/TaskTracker.java @@ -73,6 +73,7 @@ public abstract class TaskTracker { instanceInfo.setThreadConcurrency(req.getThreadConcurrency()); instanceInfo.setTaskRetryNum(req.getTaskRetryNum()); instanceInfo.setLogConfig(req.getLogConfig()); + instanceInfo.setInstanceTimeoutMS(req.getInstanceTimeoutMS()); // 特殊处理超时时间 if (instanceInfo.getInstanceTimeoutMS() <= 0) {