From 814d4321a171885e7d8b2e585976a6cac80b8e58 Mon Sep 17 00:00:00 2001 From: Echo009 Date: Thu, 18 Feb 2021 14:48:37 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E4=BF=AE=E5=A4=8D=20map=20=E7=94=9F?= =?UTF-8?q?=E6=88=90=E7=9A=84=E5=AD=90=E4=BB=BB=E5=8A=A1=E5=91=BD=E5=90=8D?= =?UTF-8?q?=E5=92=8C=E6=A0=B9=E4=BB=BB=E5=8A=A1=E5=90=8D=E6=88=96=E6=9C=80?= =?UTF-8?q?=E7=BB=88=E4=BB=BB=E5=8A=A1=E5=90=8D=E4=B8=80=E8=87=B4=E5=AF=BC?= =?UTF-8?q?=E8=87=B4=E7=9A=84=E9=97=AE=E9=A2=98=EF=BC=88=E6=97=A0=E9=99=90?= =?UTF-8?q?=E7=94=9F=E6=88=90=E5=AD=90=E4=BB=BB=E5=8A=A1=20=E6=88=96?= =?UTF-8?q?=E8=80=85=20=E7=9B=B4=E6=8E=A5=E5=A4=B1=E8=B4=A5=EF=BC=89?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../powerjob/worker/core/processor/sdk/MapProcessor.java | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/powerjob-worker/src/main/java/com/github/kfcfans/powerjob/worker/core/processor/sdk/MapProcessor.java b/powerjob-worker/src/main/java/com/github/kfcfans/powerjob/worker/core/processor/sdk/MapProcessor.java index cbe0ff58..6caa6d01 100644 --- a/powerjob-worker/src/main/java/com/github/kfcfans/powerjob/worker/core/processor/sdk/MapProcessor.java +++ b/powerjob-worker/src/main/java/com/github/kfcfans/powerjob/worker/core/processor/sdk/MapProcessor.java @@ -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."); } + // 修复 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(); // 1. 构造请求