From 8ffef58902796342d99ede3219878f50f3e7f72d Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E2=80=9Ctjq=E2=80=9D?= Date: Sat, 17 Oct 2020 16:38:35 +0800 Subject: [PATCH] feat: map and mapreduce job support worker dynamic online too --- .../worker/core/tracker/task/CommonTaskTracker.java | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/powerjob-worker/src/main/java/com/github/kfcfans/powerjob/worker/core/tracker/task/CommonTaskTracker.java b/powerjob-worker/src/main/java/com/github/kfcfans/powerjob/worker/core/tracker/task/CommonTaskTracker.java index e3f6a08e..7d6930a4 100644 --- a/powerjob-worker/src/main/java/com/github/kfcfans/powerjob/worker/core/tracker/task/CommonTaskTracker.java +++ b/powerjob-worker/src/main/java/com/github/kfcfans/powerjob/worker/core/tracker/task/CommonTaskTracker.java @@ -59,6 +59,12 @@ public class CommonTaskTracker extends TaskTracker { // 启动定时任务（任务派发 & 状态检查） scheduledPool.scheduleWithFixedDelay(new Dispatcher(), 0, 5, TimeUnit.SECONDS); scheduledPool.scheduleWithFixedDelay(new StatusCheckRunnable(), 10, 10, TimeUnit.SECONDS); + + // 如果是 MR 任务，则需要启动执行器动态检测装置 + ExecuteType executeType = ExecuteType.valueOf(req.getExecuteType()); + if (executeType == ExecuteType.MAP || executeType == ExecuteType.MAP_REDUCE) { + scheduledPool.scheduleAtFixedRate(new WorkerDetector(), 1, 1, TimeUnit.MINUTES); + } } @Override