From 34d3366278acd50e10960290e40bd146b0347baa Mon Sep 17 00:00:00 2001 From: dhb52 Date: Tue, 7 Jan 2025 20:42:10 +0800 Subject: [PATCH] =?UTF-8?q?fix:(1.3.0-beta1.1):=20=E9=9D=99=E6=80=81?= =?UTF-8?q?=E5=88=86=E7=89=87=E5=8F=82=E6=95=B0=20taskBatchId=20=E6=B2=A1?= =?UTF-8?q?=E6=9C=89=E8=AE=BE=E7=BD=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../snailjob/client/job/core/executor/AbstractJobExecutor.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/snail-job-client/snail-job-client-job-core/src/main/java/com/aizuda/snailjob/client/job/core/executor/AbstractJobExecutor.java b/snail-job-client/snail-job-client-job-core/src/main/java/com/aizuda/snailjob/client/job/core/executor/AbstractJobExecutor.java index f57f1b7fb..0c4ba9c1b 100644 --- a/snail-job-client/snail-job-client-job-core/src/main/java/com/aizuda/snailjob/client/job/core/executor/AbstractJobExecutor.java +++ b/snail-job-client/snail-job-client-job-core/src/main/java/com/aizuda/snailjob/client/job/core/executor/AbstractJobExecutor.java @@ -24,7 +24,6 @@ import com.google.common.util.concurrent.MoreExecutors; import lombok.extern.slf4j.Slf4j; import java.util.List; -import java.util.Map; import java.util.Objects; import java.util.Optional; import java.util.concurrent.ThreadPoolExecutor; @@ -112,6 +111,7 @@ public abstract class AbstractJobExecutor implements IJobExecutor { private static JobArgs buildShardingJobArgs(JobContext jobContext) { ShardingJobArgs jobArgs = new ShardingJobArgs(); jobArgs.setJobParams(jobContext.getJobArgsHolder().getJobParams()); + jobArgs.setTaskBatchId(jobContext.getTaskBatchId()); jobArgs.setExecutorInfo(jobContext.getExecutorInfo()); jobArgs.setShardingIndex(jobContext.getShardingIndex()); jobArgs.setShardingTotal(jobContext.getShardingTotal());