Fix Guava import

apache · Sep 28, 2023 · 36ba537 · 36ba537
1 parent 3f2c5e7
commit 36ba537
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 2 deletions.
diff --git a/runners/flink/src/main/java/org/apache/beam/runners/flink/metrics/FlinkMetricContainer.java b/runners/flink/src/main/java/org/apache/beam/runners/flink/metrics/FlinkMetricContainer.java
@@ -64,5 +64,4 @@ public void registerMetricsForPipelineResult() {
     }
     metricsAccumulator.add(metricsContainers);
   }
-
 }
diff --git a/...s/flink/src/main/java/org/apache/beam/runners/flink/metrics/FlinkMetricContainerBase.java b/...s/flink/src/main/java/org/apache/beam/runners/flink/metrics/FlinkMetricContainerBase.java
@@ -33,7 +33,7 @@
 import org.apache.beam.sdk.metrics.MetricResult;
 import org.apache.beam.sdk.metrics.MetricResults;
 import org.apache.beam.sdk.metrics.MetricsFilter;
-import org.apache.beam.vendor.guava.v26_0_jre.com.google.common.annotations.VisibleForTesting;
+import org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.annotations.VisibleForTesting;
 import org.apache.flink.configuration.GlobalConfiguration;
 import org.apache.flink.configuration.MetricOptions;
 import org.apache.flink.metrics.Counter;