mirror of
https://github.com/alibaba/DataX.git
synced 2025-05-02 03:01:58 +08:00
fix spped config check
This commit is contained in:
parent
d4d1ea6a15
commit
bbfbe97f83
@ -427,7 +427,7 @@ public class JobContainer extends AbstractContainer {
|
||||
Long channelLimitedByteSpeed = this.configuration
|
||||
.getLong(CoreConstant.DATAX_CORE_TRANSPORT_CHANNEL_SPEED_BYTE);
|
||||
if (channelLimitedByteSpeed == null || channelLimitedByteSpeed <= 0) {
|
||||
DataXException.asDataXException(
|
||||
throw DataXException.asDataXException(
|
||||
FrameworkErrorCode.CONFIG_ERROR,
|
||||
"在有总bps限速条件下,单个channel的bps值不能为空,也不能为非正数");
|
||||
}
|
||||
@ -448,7 +448,7 @@ public class JobContainer extends AbstractContainer {
|
||||
Long channelLimitedRecordSpeed = this.configuration.getLong(
|
||||
CoreConstant.DATAX_CORE_TRANSPORT_CHANNEL_SPEED_RECORD);
|
||||
if (channelLimitedRecordSpeed == null || channelLimitedRecordSpeed <= 0) {
|
||||
DataXException.asDataXException(FrameworkErrorCode.CONFIG_ERROR,
|
||||
throw DataXException.asDataXException(FrameworkErrorCode.CONFIG_ERROR,
|
||||
"在有总tps限速条件下,单个channel的tps值不能为空,也不能为非正数");
|
||||
}
|
||||
|
||||
|
@ -105,10 +105,23 @@ DataX 3.0 开源版本支持单机多线程模式完成同步作业运行,本
|
||||
还在为同步过程对在线存储压力影响而担心吗?新版本DataX3.0提供了包括通道(并发)、记录流、字节流三种流控模式,可以随意控制你的作业速度,让你的作业在库可以承受的范围内达到最佳的同步速度。
|
||||
|
||||
```json
|
||||
"speed": {
|
||||
"channel": 5,
|
||||
"byte": 1048576,
|
||||
"record": 10000
|
||||
{
|
||||
"core": {
|
||||
"transport" : {
|
||||
"channel": {
|
||||
"speed": {
|
||||
"record": 100
|
||||
}
|
||||
}
|
||||
}
|
||||
},
|
||||
"job": {
|
||||
"setting": {
|
||||
"speed": {
|
||||
"channel": 5
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
```
|
||||
|
||||
|
Loading…
Reference in New Issue
Block a user