gtsoft/gtsoft-snail-job-server
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects 1 Releases Wiki Activity

fix(sj_1.2.0-beta2): 判断 batchReportMapTask 返回逻辑错误

Browse Source
This commit is contained in:
dhb52 2024-09-28 22:43:10 +08:00
parent 5ca1806bbf
commit 19b13992cd
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
snail-job-client/snail-job-client-job-core/src/main/java/com/aizuda/snailjob/client/job/core/executor/MapInvokeHandler.java
View File

@ -84,7 +84,7 @@ public final class MapInvokeHandler implements InvocationHandler {
// 2. 同步发送请求
Result<Boolean> result = CLIENT.batchReportMapTask(mapTaskRequest);
if (StatusEnum.NO.getStatus() == result.getStatus() || result.getData()) {
if (StatusEnum.YES.getStatus() == result.getStatus() || result.getData()) {
SnailJobLog.LOCAL.info("Map task create successfully!. taskName:[{}] TaskId:[{}] ", nextTaskName, jobContext.getTaskId());
} else {
throw new SnailJobMapReduceException("map failed for task: " + nextTaskName);