fix issues 1983 (#1984)

Co-authored-by: hexiufeng <xiufeng.he-a0968@aqara.com>
DataLinkDC · May 23, 2023 · 1aec0c8 · 1aec0c8
1 parent ce2c3da
commit 1aec0c8
Showing 1 changed file with 16 additions and 1 deletion.
diff --git a/dinky-gateway/src/main/java/org/dinky/gateway/kubernetes/KubernetesApplicationGateway.java b/dinky-gateway/src/main/java/org/dinky/gateway/kubernetes/KubernetesApplicationGateway.java
@@ -38,6 +38,9 @@
 import java.util.ArrayList;
 import java.util.Collection;
 import java.util.List;
+import java.util.concurrent.ExecutionException;
+
+import cn.hutool.core.util.StrUtil;
 
 /**
  * KubernetesApplicationGateway
@@ -84,7 +87,19 @@ public GatewayResult submitJar() {
             while (jobStatusMessages.size() == 0 && counts > 0) {
                 Thread.sleep(1000);
                 counts--;
-                jobStatusMessages = clusterClient.listJobs().get();
+                try {
+                    jobStatusMessages = clusterClient.listJobs().get();
+                } catch (ExecutionException e) {
+                    if (StrUtil.contains(e.getMessage(), "Number of retries has been exhausted.")) {
+                        // refresh the job manager ip address
+                        clusterClient.close();
+                        clusterClient = clusterClientProvider.getClusterClient();
+                    } else {
+                        LogUtil.getError(e);
+                        throw e;
+                    }
+                }
+
                 if (jobStatusMessages.size() > 0) {
                     break;
                 }