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: 修复 map 生成的子任务命名和根任务名或最终任务名一致导致的问题（无限生成子任务 或者 直接失败）

Browse Source
This commit is contained in:
Echo009 2021-02-18 14:48:37 +08:00
parent fd36f2f8e1
commit 814d4321a1
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
powerjob-worker/src/main/java/com/github/kfcfans/powerjob/worker/core/processor/sdk/MapProcessor.java
View File

@ -40,6 +40,12 @@ public abstract class MapProcessor implements BasicProcessor {
log.warn("[MapProcessor] map task size is too large, network maybe overload... please try to split the tasks."); log.warn("[MapProcessor] map task size is too large, network maybe overload... please try to split the tasks.");
} }
// 修复 map 任务命名和根任务名或者最终任务名称一致导致的问题（无限生成子任务或者直接失败）
if (TaskConstant.ROOT_TASK_NAME.equals(taskName) || TaskConstant.LAST_TASK_NAME.equals(taskName)) {
log.warn("[MapProcessor] illegal map task name : {}! please do not use 'OMS_ROOT_TASK' or 'OMS_LAST_TASK' as map task name. as a precaution, it will be renamed 'X-{}' automatically.",taskName,taskName);
taskName ="X-"+taskName;
}
TaskDO task = ThreadLocalStore.getTask(); TaskDO task = ThreadLocalStore.getTask();
// 1. 构造请求 // 1. 构造请求