Optimized the printing of K8S logs (#3842)

DataLinkDC · Sep 27, 2024 · dacbb56 · dacbb56
1 parent 7abe338
commit dacbb56
Showing 1 changed file with 6 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
@@ -184,7 +184,12 @@ public KubernetesResult waitForJmAndJobStart(
                 try (ClusterClient<String> client = clusterClient.getClusterClient()) {
                     logger.info("Start get job list ....");
                     Collection<JobStatusMessage> jobList = client.listJobs().get(15, TimeUnit.SECONDS);
-                    logger.info("Get K8S Job list: {}", jobList);
+                    if (jobList == null) {
+                        logger.error("Get job list is failed, Please check your Network !!");
+                        continue;
+                    } else {
+                        logger.info("Get K8S Job list: {}", jobList);
+                    }
                     if (jobList.isEmpty()) {
                         logger.error("Get job is empty, will be reconnect later....");
                         continue;