address comment

apache · Mar 25, 2020 · 9ff5ca2 · 9ff5ca2
1 parent 02537b3
commit 9ff5ca2
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/.../network-common/src/main/java/org/apache/spark/network/client/TransportClientFactory.java b/.../network-common/src/main/java/org/apache/spark/network/client/TransportClientFactory.java
@@ -87,6 +87,7 @@ private static class ClientPool {
   private EventLoopGroup workerGroup;
   private final PooledByteBufAllocator pooledAllocator;
   private final NettyMemoryMetrics metrics;
+  private final double fastFailTimeWindow;
 
   public TransportClientFactory(
       TransportContext context,
@@ -113,6 +114,7 @@ public TransportClientFactory(
     }
     this.metrics = new NettyMemoryMetrics(
       this.pooledAllocator, conf.getModuleName() + "-client", conf);
+    fastFailTimeWindow = conf.ioRetryWaitTimeMs() * 0.95;
   }
 
   public MetricSet getAllMetrics() {
@@ -193,7 +195,6 @@ public TransportClient createClient(String remoteHost, int remotePort)
           logger.info("Found inactive connection to {}, creating a new one.", resolvedAddress);
         }
       }
-      double fastFailTimeWindow = conf.ioRetryWaitTimeMs() * 0.95;
       if (conf.maxIORetries() > 0 && System.currentTimeMillis() - clientPool.lastConnectionFailed <
         fastFailTimeWindow) {
         throw new IOException(