[flink] branch release-1.13 updated: [FLINK-23628][metrics][influxdb] Fix test setup

[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 7079093  [FLINK-23628][metrics][influxdb] Fix test setup
7079093 is described below

commit 707909394e0c3440f8857c048d996ee365e6be8e
Author: Chesnay Schepler <ches...@apache.org>
AuthorDate: Wed Aug 4 17:31:34 2021 +0200

    [FLINK-23628][metrics][influxdb] Fix test setup
---
 .../org/apache/flink/metrics/influxdb/MeasurementInfoProviderTest.java  | 2 ++
 1 file changed, 2 insertions(+)

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 2824001..4002246 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
@@ -69,6 +69,7 @@ public class MeasurementInfoProviderTest extends TestLogger {
 
     @Test
     public void testNormalizingTags() {
+        String logicalScope = "myService.Status.JVM.ClassLoader";
         Map<String, String> variables = new HashMap<>();
         variables.put("<A\n>", "a\n");
 
@@ -79,6 +80,7 @@ public class MeasurementInfoProviderTest extends TestLogger {
                             throw new 
UnsupportedOperationException("unexpected method call");
                         });
         doReturn(variables).when(metricGroup).getAllVariables();
+        doReturn(logicalScope).when(metricGroup).getLogicalScope(any(), 
anyChar());
 
         MeasurementInfo info = provider.getMetricInfo("m1", metricGroup);
         assertThat(info.getTags(), hasEntry("A", "a"));