Merge branch 'hotfix_1.8_3.10.x_29420' into '1.8_test_3.10.x'

【29420】解决速度限制不起作用BUG

See merge request dt-insight-engine/flinkx!146

Author: dujie

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

@@ -189,6 +189,8 @@ private static void speedTest(DataTransferConfig config) {
         } else if (WRITER.equalsIgnoreCase(testConfig.getSpeedTest())){
             ContentConfig contentConfig = config.getJob().getContent().get(0);
             contentConfig.getReader().setName(STREAM_READER);
+        }else {
+            return;
         }
 
         config.getJob().getSetting().getSpeed().setBytes(-1);

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

@@ -87,7 +87,7 @@ private void updateRate(){
         BigDecimal thisWriteRatio = BigDecimal.valueOf(totalRecords == 0 ? 0 : thisRecords / (double) totalRecords);
 
         if (totalRecords > MIN_RECORD_NUMBER_UPDATE_RATE && totalBytes != 0
-                && thisWriteRatio.compareTo(new BigDecimal(0)) == 0) {
+                && thisWriteRatio.compareTo(BigDecimal.ZERO) != 0) {
             double bpr = totalBytes / (double)totalRecords;
             double permitsPerSecond = expectedBytePerSecond / bpr * thisWriteRatio.doubleValue();
             rateLimiter.setRate(permitsPerSecond);