[flink] branch release-1.13 updated: [FLINK-23619][metrics][influxdb] Fix compile issue

[chesnay]

This is an automated email from the ASF dual-hosted git repository.

chesnay pushed a commit to branch release-1.13
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.13 by this push:
     new 06de69c  [FLINK-23619][metrics][influxdb] Fix compile issue
06de69c is described below

commit 06de69cb8b1f70a1194886a19e47d9db846851db
Author: Chesnay Schepler <ches...@apache.org>
AuthorDate: Wed Aug 4 12:08:44 2021 +0200

    [FLINK-23619][metrics][influxdb] Fix compile issue
---
 .../flink/metrics/influxdb/MeasurementInfoProviderTest.java      | 9 +++++++--
 1 file changed, 7 insertions(+), 2 deletions(-)

diff --git 
a/flink-metrics/flink-metrics-influxdb/src/test/java/org/apache/flink/metrics/influxdb/MeasurementInfoProviderTest.java
 
b/flink-metrics/flink-metrics-influxdb/src/test/java/org/apache/flink/metrics/influxdb/MeasurementInfoProviderTest.java
index 669033e..2824001 100644
--- 
a/flink-metrics/flink-metrics-influxdb/src/test/java/org/apache/flink/metrics/influxdb/MeasurementInfoProviderTest.java
+++ 
b/flink-metrics/flink-metrics-influxdb/src/test/java/org/apache/flink/metrics/influxdb/MeasurementInfoProviderTest.java
@@ -72,8 +72,13 @@ public class MeasurementInfoProviderTest extends TestLogger {
         Map<String, String> variables = new HashMap<>();
         variables.put("<A\n>", "a\n");
 
-        final MetricGroup metricGroup =
-                TestMetricGroup.newBuilder().setVariables(variables).build();
+        FrontMetricGroup metricGroup =
+                mock(
+                        FrontMetricGroup.class,
+                        (invocation) -> {
+                            throw new 
UnsupportedOperationException("unexpected method call");
+                        });
+        doReturn(variables).when(metricGroup).getAllVariables();
 
         MeasurementInfo info = provider.getMetricInfo("m1", metricGroup);
         assertThat(info.getTags(), hasEntry("A", "a"));