Skip to content

Commit

Permalink
[hotfix][metrics] Fix compile issue
Browse files Browse the repository at this point in the history
  • Loading branch information
zentol committed Aug 10, 2021
1 parent bd95c72 commit 760fa44
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -32,8 +32,8 @@
import org.apache.flink.runtime.metrics.groups.OperatorIOMetricGroup;
import org.apache.flink.runtime.metrics.groups.OperatorMetricGroup;
import org.apache.flink.runtime.metrics.groups.TaskIOMetricGroup;
import org.apache.flink.runtime.metrics.groups.TaskManagerMetricGroup;
import org.apache.flink.runtime.metrics.groups.TaskMetricGroup;
import org.apache.flink.runtime.metrics.util.MetricUtils;
import org.apache.flink.runtime.operators.BatchTask;
import org.apache.flink.runtime.operators.DriverStrategy;
import org.apache.flink.runtime.operators.FlatMapDriver;
Expand Down Expand Up @@ -78,7 +78,7 @@ public void testOperatorIOMetricReuse() throws Exception {
.setInputSplitProvider(this.inputSplitProvider)
.setBufferSize(NETWORK_BUFFER_SIZE)
.setMetricGroup(
MetricUtils.createTaskManagerMetricGroup(
TaskManagerMetricGroup.createTaskManagerMetricGroup(
NoOpMetricRegistry.INSTANCE,
"host",
ResourceID.generate())
Expand Down

0 comments on commit 760fa44

Please sign in to comment.