Merge branch '1.8_release_4.0.x' into 1.10_release_4.0.x

gituser · gituser · commit 18b11b036749 · 2020-11-17T17:41:02.000+08:00
diff --git a/flinkx-core/src/main/java/com/dtstack/flinkx/metrics/BaseMetric.java b/flinkx-core/src/main/java/com/dtstack/flinkx/metrics/BaseMetric.java
@@ -56,7 +56,7 @@ public void addMetric(String metricName, LongCounter counter, boolean meterView)
         metricCounters.put(metricName, counter);
         flinkxOutput.gauge(metricName, new SimpleAccumulatorGauge<Long>(counter));
         if (meterView){
-            flinkxOutput.meter(metricName + Metrics.SUFFIX_RATE, new SimpleLongCounterMeterView(counter, 60));
+            flinkxOutput.meter(metricName + Metrics.SUFFIX_RATE, new SimpleLongCounterMeterView(counter, 20));
         }
     }
 

Original file line number	Diff line number	Diff line change
`@@ -56,7 +56,7 @@ public void addMetric(String metricName, LongCounter counter, boolean meterView)`
`56`	`56`	`metricCounters.put(metricName, counter);`
`57`	`57`	`flinkxOutput.gauge(metricName, new SimpleAccumulatorGauge<Long>(counter));`
`58`	`58`	`if (meterView){`
`59`		`- flinkxOutput.meter(metricName + Metrics.SUFFIX_RATE, new SimpleLongCounterMeterView(counter, 60));`
	`59`	`+ flinkxOutput.meter(metricName + Metrics.SUFFIX_RATE, new SimpleLongCounterMeterView(counter, 20));`
`60`	`60`	`}`
`61`	`61`	`}`
`62`	`62`