FileSystemWorkerThriftPool implememntation

core/client/src/main/java/alluxio/client/ClientContext.java

@@ -14,13 +14,10 @@
 import alluxio.Configuration;
 import alluxio.PropertyKey;
 import alluxio.metrics.MetricsSystem;
-import alluxio.util.ThreadFactoryUtils;
 
 import com.google.common.base.Preconditions;
 
 import java.net.InetSocketAddress;
-import java.util.concurrent.ExecutorService;
-import java.util.concurrent.Executors;
 
 import javax.annotation.concurrent.NotThreadSafe;
 
@@ -30,7 +27,6 @@
  */
 @NotThreadSafe
 public final class ClientContext {
-  private static ExecutorService sFileClientExecutorService;
   private static InetSocketAddress sMasterAddress;
 
   static {
@@ -46,13 +42,6 @@ public final class ClientContext {
    * This method requires that configuration has been initialized.
    */
   public static void init() {
-    if (sFileClientExecutorService != null) {
-      sFileClientExecutorService.shutdownNow();
-    }
-    sFileClientExecutorService = Executors
-        .newFixedThreadPool(Configuration.getInt(PropertyKey.USER_FILE_WORKER_CLIENT_THREADS),
-            ThreadFactoryUtils.build("file-worker-heartbeat-%d", true));
-
     String masterHostname =
         Preconditions.checkNotNull(Configuration.get(PropertyKey.MASTER_HOSTNAME));
     int masterPort = Configuration.getInt(PropertyKey.MASTER_RPC_PORT);
@@ -68,12 +57,5 @@ public static InetSocketAddress getMasterAddress() {
     return sMasterAddress;
   }
 
-  /**
-   * @return the executor service for file clients
-   */
-  public static ExecutorService getFileClientExecutorService() {
-    return sFileClientExecutorService;
-  }
-
   private ClientContext() {} // prevent instantiation
 }

core/client/src/main/java/alluxio/client/file/FileSystemContext.java

@@ -90,8 +90,7 @@ public FileSystemWorkerClient createWorkerClient() throws IOException {
       address = mWorkerAddresses.get(ThreadLocalRandom.current().nextInt(mWorkerAddresses.size()));
     }
     long sessionId = IdUtils.getRandomNonNegativeLong();
-    return new FileSystemWorkerClient(address, ClientContext.getFileClientExecutorService(),
-        sessionId);
+    return new FileSystemWorkerClient(address, sessionId);
   }
 
   /**