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

gituser · gituser · commit 368ee5f56723 · 2021-02-05T17:05:15.000+08:00
diff --git a/core/src/main/java/com/dtstack/flink/sql/watermarker/AbstractCustomerWaterMarker.java b/core/src/main/java/com/dtstack/flink/sql/watermarker/AbstractCustomerWaterMarker.java
@@ -92,7 +92,6 @@ public IterationRuntimeContext getIterationRuntimeContext() {
     public void setRuntimeContext(RuntimeContext t) {
         this.runtimeContext = t;
         eventDelayGauge = new EventDelayGauge();
-        t.getMetricGroup().getAllVariables().put("<source_tag>", fromSourceTag);
         t.getMetricGroup().gauge(MetricConstant.DT_EVENT_DELAY_GAUGE, eventDelayGauge);
     }
 

Original file line number	Diff line number	Diff line change
`@@ -92,7 +92,6 @@ public IterationRuntimeContext getIterationRuntimeContext() {`
`92`	`92`	`public void setRuntimeContext(RuntimeContext t) {`
`93`	`93`	`this.runtimeContext = t;`
`94`	`94`	`eventDelayGauge = new EventDelayGauge();`
`95`		`- t.getMetricGroup().getAllVariables().put("<source_tag>", fromSourceTag);`
`96`	`95`	`t.getMetricGroup().gauge(MetricConstant.DT_EVENT_DELAY_GAUGE, eventDelayGauge);`
`97`	`96`	`}`
`98`	`97`