Skip to content

Commit 51c7469

Browse files
committed
[FLINK-37596] Remove redundant metricGroup initialization
1 parent 4ac0ca8 commit 51c7469

File tree

1 file changed

+0
-2
lines changed

1 file changed

+0
-2
lines changed

flink-runtime/src/test/java/org/apache/flink/streaming/api/operators/source/TestingSourceOperator.java

-2
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,6 @@
2727
import org.apache.flink.configuration.Configuration;
2828
import org.apache.flink.core.fs.CloseableRegistry;
2929
import org.apache.flink.runtime.execution.Environment;
30-
import org.apache.flink.runtime.metrics.groups.UnregisteredMetricGroups;
3130
import org.apache.flink.runtime.operators.coordination.MockOperatorEventGateway;
3231
import org.apache.flink.runtime.operators.coordination.OperatorEventGateway;
3332
import org.apache.flink.runtime.operators.testutils.MockEnvironmentBuilder;
@@ -103,7 +102,6 @@ public TestingSourceOperator(
103102

104103
this.subtaskIndex = subtaskIndex;
105104
this.parallelism = parallelism;
106-
this.metrics = UnregisteredMetricGroups.createUnregisteredOperatorMetricGroup();
107105
initSourceMetricGroup();
108106

109107
// unchecked wrapping is okay to keep tests simpler

0 commit comments

Comments
 (0)