[Optimization][admin] NULL may be used when optimizing heartbeat dete…

…ction of cluster instances (#3275) Co-authored-by: czs <[email protected]>
DataLinkDC · Jul 14, 2024 · 4417599 · 4417599
1 parent 31915db
commit 4417599
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/dinky-admin/src/main/java/org/dinky/assertion/DinkyAssert.java b/dinky-admin/src/main/java/org/dinky/assertion/DinkyAssert.java
@@ -33,6 +33,9 @@
 public interface DinkyAssert {
 
     static void check(ClusterInstance clusterInstance) {
+        if (clusterInstance == null) {
+            throw new BusException(Status.CLUSTER_NOT_EXIST);
+        }
         if (clusterInstance.getId() == null) {
             throw new BusException("Flink 集群【" + clusterInstance.getId() + "】不存在");
         }