fix bad import

apache · Apr 11, 2024 · f787938 · f787938
1 parent 37a5c60
commit f787938
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/.../src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/GetDataClient.java b/.../src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/GetDataClient.java
@@ -17,7 +17,6 @@
  */
 package org.apache.beam.runners.dataflow.worker.windmill.client;
 
-import com.google.common.util.concurrent.ThreadFactoryBuilder;
 import java.io.PrintWriter;
 import java.util.ArrayList;
 import java.util.List;
@@ -35,6 +34,7 @@
 import org.apache.beam.runners.dataflow.worker.windmill.Windmill.KeyedGetDataResponse;
 import org.apache.beam.runners.dataflow.worker.windmill.client.WindmillStream.GetDataStream;
 import org.apache.beam.sdk.annotations.Internal;
+import org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.util.concurrent.ThreadFactoryBuilder;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -43,6 +43,7 @@
 @ThreadSafe
 public final class GetDataClient {
   private static final Logger LOG = LoggerFactory.getLogger(GetDataClient.class);
+  private static final String FAN_OUT_REFRESH_WORK_EXECUTOR = "FanOutActiveWorkRefreshExecutor";
 
   private final AtomicInteger activeSideInputReads;
   private final AtomicInteger activeStateReads;
@@ -57,7 +58,7 @@ public GetDataClient(MemoryMonitor gcThrashingMonitor) {
     this.activeHeartbeats = new AtomicInteger();
     this.fanOutActiveWorkRefreshExecutor =
         Executors.newCachedThreadPool(
-            new ThreadFactoryBuilder().setNameFormat("FanOutActiveWorkRefreshExecutor").build());
+            new ThreadFactoryBuilder().setNameFormat(FAN_OUT_REFRESH_WORK_EXECUTOR).build());
   }
 
   public KeyedGetDataResponse getState(