Fix create worker process timeout #13771

Author: “shenghui361”

core/common/src/main/java/alluxio/conf/PropertyKey.java

@@ -3508,6 +3508,13 @@ public String toString() {
           .setConsistencyCheckLevel(ConsistencyCheckLevel.WARN)
           .setScope(Scope.WORKER)
           .build();
+  public static final PropertyKey WORKER_REGISTRY_GET_TIMEOUT_MS  =
+      new Builder(Name.WORKER_REGISTRY_GET_TIMEOUT_MS)
+          .setDefaultValue("600000")
+          .setDescription("The timeout of getting a worker from the registry.")
+          .setConsistencyCheckLevel(ConsistencyCheckLevel.IGNORE)
+          .setScope(Scope.WORKER)
+          .build();
 
   //
   // Proxy related properties
@@ -5935,6 +5942,8 @@ public static final class Name {
         "alluxio.worker.ufs.instream.cache.enabled";
     public static final String WORKER_UFS_INSTREAM_CACHE_MAX_SIZE =
         "alluxio.worker.ufs.instream.cache.max.size";
+    public static final String WORKER_REGISTRY_GET_TIMEOUT_MS =
+        "alluxio.worker.registry.get.timeout";
 
     //
     // Proxy related properties

core/server/worker/src/main/java/alluxio/worker/AlluxioWorkerProcess.java

@@ -116,7 +116,7 @@ public final class AlluxioWorkerProcess implements WorkerProcess {
       // registered at worker registry, so the maximum timeout here is set to the multiply of
       // the number of factories by the default timeout of getting a worker from the registry.
       CommonUtils.invokeAll(callables,
-          (long) callables.size() * 10 * Constants.DEFAULT_REGISTRY_GET_TIMEOUT_MS);
+          (long) callables.size() * ServerConfiguration.getLong(PropertyKey.WORKER_REGISTRY_GET_TIMEOUT_MS));
 
       // Setup web server
       mWebServer =