fix unknown jobid bug (DataLinkDC#2206)

Co-authored-by: chengsheng <[email protected]>
aiwenmo · Aug 15, 2023 · f5244d5 · f5244d5
1 parent b0c7ca3
commit f5244d5
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/dlink-gateway/src/main/java/com/dlink/gateway/kubernetes/KubernetesApplicationGateway.java b/dlink-gateway/src/main/java/com/dlink/gateway/kubernetes/KubernetesApplicationGateway.java
@@ -127,7 +127,11 @@ public GatewayResult submitJar() {
             // if JobStatusMessage not have job id, use timestamp
             // and... it`s maybe wrong with submit
             if (TextUtils.isEmpty(jobId)) {
-                jobId = "unknown" + System.currentTimeMillis();
+                int cost = SystemConfiguration.getInstances().getJobIdWait() - counts;
+                String clusterId = clusterClient.getClusterId();
+                throw new Exception(
+                        "Unable to obtain jobId. Please contact management to troubleshoot the issue,Waiting time："
+                                + cost + "s,job name:" + clusterId);
             }
             result.setClusterId(jobId);
             result.setWebURL(clusterClient.getWebInterfaceURL());