diff --git a/dinky-admin/src/main/java/org/dinky/assertion/DinkyAssert.java b/dinky-admin/src/main/java/org/dinky/assertion/DinkyAssert.java index b0a99e3bbf..e6c106c775 100644 --- 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() + "】不存在"); }