optimize_no_flink_deps_no_start_dinky

DataLinkDC · Nov 26, 2024 · aaf1bb0 · aaf1bb0
1 parent 6995769
commit aaf1bb0
Show file tree

Hide file tree

Showing 4 changed files with 8 additions and 8 deletions.
diff --git a/dinky-admin/src/main/java/org/dinky/controller/FlinkController.java b/dinky-admin/src/main/java/org/dinky/controller/FlinkController.java
@@ -19,7 +19,6 @@
 
 package org.dinky.controller;
 
-import cn.hutool.core.lang.Singleton;
 import org.dinky.data.model.CheckPointReadTable;
 import org.dinky.data.result.Result;
 import org.dinky.data.vo.CascaderVO;
@@ -34,6 +33,7 @@
 import org.springframework.web.bind.annotation.RestController;
 
 import cn.dev33.satoken.annotation.SaCheckLogin;
+import cn.hutool.core.lang.Singleton;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import lombok.RequiredArgsConstructor;

diff --git a/dinky-admin/src/main/java/org/dinky/controller/TaskController.java b/dinky-admin/src/main/java/org/dinky/controller/TaskController.java
@@ -313,7 +313,7 @@ public Result<FlinkJarSqlConvertVO> flinkJarSqlConvertForm(@RequestBody TaskDTO
         }
         Integer lastExecuteJarSqlStatementIndex = null;
         for (int i = 0; i < statements.length; i++) {
-                if (ExecuteJarParseStrategyUtil.match(statements[i])) {
+            if (ExecuteJarParseStrategyUtil.match(statements[i])) {
                 lastExecuteJarSqlStatementIndex = i;
             }
         }

diff --git a/dinky-admin/src/main/java/org/dinky/init/FlinkHistoryServer.java b/dinky-admin/src/main/java/org/dinky/init/FlinkHistoryServer.java
@@ -58,8 +58,6 @@ public class FlinkHistoryServer implements ApplicationRunner {
     private final SystemConfiguration systemConfiguration = SystemConfiguration.getInstances();
     private final SysConfigService sysConfigService;
 
-
-
     public FlinkHistoryServer(JobInstanceService jobInstanceService, SysConfigService sysConfigService) {
         this.sysConfigService = sysConfigService;
         this.historyRunnable = () -> {

diff --git a/dinky-admin/src/main/java/org/dinky/init/SystemInit.java b/dinky-admin/src/main/java/org/dinky/init/SystemInit.java
@@ -109,10 +109,12 @@ public void run(ApplicationArguments args) {
             updateGitBuildState();
             registerURL();
         } catch (NoClassDefFoundError e) {
-            if (e.getMessage().contains("org/apache/flink")){
-                log.error("No Flink Jar dependency detected, please put the Flink Jar dependency into the DInky program first. (未检测到有 Flink Jar依赖，请先放入 Flink Jar 依赖到 DInky程序里)",e);
-            }else {
-                log.error("",e);
+            if (e.getMessage().contains("org/apache/flink")) {
+                log.error(
+                        "No Flink Jar dependency detected, please put the Flink Jar dependency into the DInky program first. (未检测到有 Flink Jar依赖，请先放入 Flink Jar 依赖到 DInky程序里)",
+                        e);
+            } else {
+                log.error("", e);
             }
         }
     }