[Optimization-4270] Check if the cluster is disabled before starting the flink session (#4330)

Author: aiwenmo

dinky-admin/src/main/java/org/dinky/service/impl/ClusterConfigurationServiceImpl.java

@@ -74,8 +74,8 @@ public List<ClusterConfiguration> listAllClusterConfig() {
     @Override
     public FlinkClusterConfig getAndCheckEnableFlinkClusterCfg(Integer id) {
         ClusterConfiguration cfg = this.getClusterConfigById(id);
-        DinkyAssert.checkNull(cfg, "The clusterConfiguration not exists!");
-        DinkyAssert.checkEnable(cfg, "The clusterConfiguration is Disable!");
+        DinkyAssert.checkNull(cfg, "The cluster configuration does not exist.");
+        DinkyAssert.checkEnable(cfg, "The cluster configuration has been disabled.");
         return FlinkClusterConfig.create(cfg.getType(), cfg.getConfigJson());
     }
 

dinky-admin/src/main/java/org/dinky/service/impl/ClusterInstanceServiceImpl.java

@@ -32,7 +32,6 @@
 import org.dinky.data.model.ClusterInstance;
 import org.dinky.data.model.Task;
 import org.dinky.gateway.config.GatewayConfig;
-import org.dinky.gateway.exception.GatewayException;
 import org.dinky.gateway.model.FlinkClusterConfig;
 import org.dinky.gateway.result.GatewayResult;
 import org.dinky.job.JobConfig;
@@ -227,9 +226,8 @@ public void killCluster(Integer id) {
     @Override
     public ClusterInstance deploySessionCluster(Integer id) {
         ClusterConfiguration clusterCfg = clusterConfigurationService.getClusterConfigById(id);
-        if (Asserts.isNull(clusterCfg)) {
-            throw new GatewayException("The cluster configuration does not exist.");
-        }
+        DinkyAssert.checkNull(clusterCfg, "The cluster configuration does not exist.");
+        DinkyAssert.checkEnable(clusterCfg, "The cluster configuration has been disabled.");
         GatewayConfig gatewayConfig =
                 GatewayConfig.build(FlinkClusterConfig.create(clusterCfg.getType(), clusterCfg.getConfigJson()));
         gatewayConfig.setType(gatewayConfig.getType().getSessionType());