Skip to content

Commit 412969a

Browse files
committed
【29420】解决速度限制不起作用BUG
1 parent 3bc3acf commit 412969a

File tree

2 files changed

+3
-1
lines changed

2 files changed

+3
-1
lines changed

flinkx-core/src/main/java/com/dtstack/flinkx/Main.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -184,6 +184,8 @@ private static void speedTest(DataTransferConfig config) {
184184
} else if (WRITER.equalsIgnoreCase(testConfig.getSpeedTest())){
185185
ContentConfig contentConfig = config.getJob().getContent().get(0);
186186
contentConfig.getReader().setName(STREAM_READER);
187+
}else {
188+
return;
187189
}
188190

189191
config.getJob().getSetting().getSpeed().setBytes(-1);

flinkx-core/src/main/java/com/dtstack/flinkx/reader/ByteRateLimiter.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -87,7 +87,7 @@ private void updateRate(){
8787
BigDecimal thisWriteRatio = BigDecimal.valueOf(totalRecords == 0 ? 0 : thisRecords / (double) totalRecords);
8888

8989
if (totalRecords > MIN_RECORD_NUMBER_UPDATE_RATE && totalBytes != 0
90-
&& thisWriteRatio.compareTo(new BigDecimal(0)) == 0) {
90+
&& thisWriteRatio.compareTo(BigDecimal.ZERO) != 0) {
9191
double bpr = totalBytes / (double)totalRecords;
9292
double permitsPerSecond = expectedBytePerSecond / bpr * thisWriteRatio.doubleValue();
9393
rateLimiter.setRate(permitsPerSecond);

0 commit comments

Comments
 (0)