From feb299eecc06243bcf42bf8d4fc1c050309e1db9 Mon Sep 17 00:00:00 2001 From: huzekang <1040080742@qq.com> Date: Sun, 7 Apr 2019 03:00:05 +0800 Subject: [PATCH] =?UTF-8?q?change=EF=BC=9A=201.=E4=BC=98=E5=8C=96=E6=B3=A8?= =?UTF-8?q?=E9=87=8A?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- core/src/main/java/com/alibaba/datax/core/job/JobContainer.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/src/main/java/com/alibaba/datax/core/job/JobContainer.java b/core/src/main/java/com/alibaba/datax/core/job/JobContainer.java index 50f1cf7b..acc552cc 100755 --- a/core/src/main/java/com/alibaba/datax/core/job/JobContainer.java +++ b/core/src/main/java/com/alibaba/datax/core/job/JobContainer.java @@ -467,7 +467,7 @@ public class JobContainer extends AbstractContainer { if (this.needChannelNumber < Integer.MAX_VALUE) { return; } - + // 通过channel调节Job运行速度 boolean isChannelLimit = (this.configuration.getInt( CoreConstant.DATAX_JOB_SETTING_SPEED_CHANNEL, 0) > 0); if (isChannelLimit) {