Increase the timeout when fetch instance list

1996fanrui · Mar 27, 2024 · aae6152 · aae6152
1 parent 3595d15
commit aae6152
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/...tandalone/src/main/java/org/apache/flink/autoscaler/standalone/flinkmanager/FMClient.java b/...tandalone/src/main/java/org/apache/flink/autoscaler/standalone/flinkmanager/FMClient.java
@@ -47,6 +47,8 @@ public static FMClient getInstance() {
             // FMClient newClient = new FMClient(GlobalConfiguration.getGlobalConfiguration());
             final Configuration conf = new Configuration();
             conf.setString("flink-common.fm.address", "https://flink.idata.shopeemobile.com");
+            conf.setString("flink-common.fm.connection-timeout", "40s");
+
             FMClient newClient = new FMClient(conf);
             if (INSTANCE_HOLDER.compareAndSet(null, newClient)) {
                 return newClient;