Skip to content

Commit 71a5760

Browse files
committed
[fix-35290][core] fix watermark metrics throw a warning log
1 parent d022e4b commit 71a5760

File tree

1 file changed

+0
-1
lines changed

1 file changed

+0
-1
lines changed

core/src/main/java/com/dtstack/flink/sql/watermarker/AbstractCustomerWaterMarker.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -92,7 +92,6 @@ public IterationRuntimeContext getIterationRuntimeContext() {
9292
public void setRuntimeContext(RuntimeContext t) {
9393
this.runtimeContext = t;
9494
eventDelayGauge = new EventDelayGauge();
95-
t.getMetricGroup().getAllVariables().put("<source_tag>", fromSourceTag);
9695
t.getMetricGroup().gauge(MetricConstant.DT_EVENT_DELAY_GAUGE, eventDelayGauge);
9796
}
9897

0 commit comments

Comments
 (0)