fix dinky app not throw exception

gaoyan1998 · Dec 26, 2023 · a4a4b54 · a4a4b54
1 parent a4c4b09
commit a4a4b54
Show file tree

Hide file tree

Showing 7 changed files with 31 additions and 50 deletions.
diff --git a/dinky-app/dinky-app-1.14/src/main/java/org/dinky/app/MainApp.java b/dinky-app/dinky-app-1.14/src/main/java/org/dinky/app/MainApp.java
@@ -49,15 +49,10 @@ public static void main(String[] args) throws Exception {
         String config = parameters.get(AppParamConstant.config);
         config = isEncrypt ? new String(Base64.getDecoder().decode(config)) : config;
         AppParamConfig appConfig = JsonUtils.toJavaBean(config, AppParamConfig.class);
-        try {
-            log.info("dinky app is Ready to run, config is {}", appConfig);
-            DBUtil.init(appConfig);
-            Submitter.submit(appConfig);
-        } catch (Exception e) {
-            log.error("exectue app failed : ", e);
-        } finally {
-            log.info("Start Monitor Job");
-            FlinkAppUtil.monitorFlinkTask(Submitter.executor, appConfig.getTaskId());
-        }
+        log.info("dinky app is Ready to run, config is {}", appConfig);
+        DBUtil.init(appConfig);
+        Submitter.submit(appConfig);
+        log.info("Start Monitor Job");
+        FlinkAppUtil.monitorFlinkTask(Submitter.executor, appConfig.getTaskId());
     }
 }
diff --git a/dinky-app/dinky-app-1.15/src/main/java/org/dinky/app/MainApp.java b/dinky-app/dinky-app-1.15/src/main/java/org/dinky/app/MainApp.java
@@ -49,15 +49,10 @@ public static void main(String[] args) throws Exception {
         String config = parameters.get(AppParamConstant.config);
         config = isEncrypt ? new String(Base64.getDecoder().decode(config)) : config;
         AppParamConfig appConfig = JsonUtils.toJavaBean(config, AppParamConfig.class);
-        try {
-            log.info("dinky app is Ready to run, config is {}", appConfig);
-            DBUtil.init(appConfig);
-            Submitter.submit(appConfig);
-        } catch (Exception e) {
-            log.error("exectue app failed : ", e);
-        } finally {
-            log.info("Start Monitor Job");
-            FlinkAppUtil.monitorFlinkTask(Submitter.executor, appConfig.getTaskId());
-        }
+        log.info("dinky app is Ready to run, config is {}", appConfig);
+        DBUtil.init(appConfig);
+        Submitter.submit(appConfig);
+        log.info("Start Monitor Job");
+        FlinkAppUtil.monitorFlinkTask(Submitter.executor, appConfig.getTaskId());
     }
 }
diff --git a/dinky-app/dinky-app-1.16/src/main/java/org/dinky/app/MainApp.java b/dinky-app/dinky-app-1.16/src/main/java/org/dinky/app/MainApp.java
@@ -49,15 +49,10 @@ public static void main(String[] args) throws Exception {
         String config = parameters.get(AppParamConstant.config);
         config = isEncrypt ? new String(Base64.getDecoder().decode(config)) : config;
         AppParamConfig appConfig = JsonUtils.toJavaBean(config, AppParamConfig.class);
-        try {
-            log.info("dinky app is Ready to run, config is {}", appConfig);
-            DBUtil.init(appConfig);
-            Submitter.submit(appConfig);
-        } catch (Exception e) {
-            log.error("exectue app failed : ", e);
-        } finally {
-            log.info("Start Monitor Job");
-            FlinkAppUtil.monitorFlinkTask(Submitter.executor, appConfig.getTaskId());
-        }
+        log.info("dinky app is Ready to run, config is {}", appConfig);
+        DBUtil.init(appConfig);
+        Submitter.submit(appConfig);
+        log.info("Start Monitor Job");
+        FlinkAppUtil.monitorFlinkTask(Submitter.executor, appConfig.getTaskId());
     }
 }
diff --git a/dinky-app/dinky-app-1.17/src/main/java/org/dinky/app/MainApp.java b/dinky-app/dinky-app-1.17/src/main/java/org/dinky/app/MainApp.java
@@ -49,15 +49,10 @@ public static void main(String[] args) throws Exception {
         String config = parameters.get(AppParamConstant.config);
         config = isEncrypt ? new String(Base64.getDecoder().decode(config)) : config;
         AppParamConfig appConfig = JsonUtils.toJavaBean(config, AppParamConfig.class);
-        try {
-            log.info("dinky app is Ready to run, config is {}", appConfig);
-            DBUtil.init(appConfig);
-            Submitter.submit(appConfig);
-        } catch (Exception e) {
-            log.error("exectue app failed : ", e);
-        } finally {
-            log.info("Start Monitor Job");
-            FlinkAppUtil.monitorFlinkTask(Submitter.executor, appConfig.getTaskId());
-        }
+        log.info("dinky app is Ready to run, config is {}", appConfig);
+        DBUtil.init(appConfig);
+        Submitter.submit(appConfig);
+        log.info("Start Monitor Job");
+        FlinkAppUtil.monitorFlinkTask(Submitter.executor, appConfig.getTaskId());
     }
 }
diff --git a/dinky-app/dinky-app-1.18/src/main/java/org/dinky/app/MainApp.java b/dinky-app/dinky-app-1.18/src/main/java/org/dinky/app/MainApp.java
@@ -49,15 +49,10 @@ public static void main(String[] args) throws Exception {
         String config = parameters.get(AppParamConstant.config);
         config = isEncrypt ? new String(Base64.getDecoder().decode(config)) : config;
         AppParamConfig appConfig = JsonUtils.toJavaBean(config, AppParamConfig.class);
-        try {
-            log.info("dinky app is Ready to run, config is {}", appConfig);
-            DBUtil.init(appConfig);
-            Submitter.submit(appConfig);
-        } catch (Exception e) {
-            log.error("exectue app failed : ", e);
-        } finally {
-            log.info("Start Monitor Job");
-            FlinkAppUtil.monitorFlinkTask(Submitter.executor, appConfig.getTaskId());
-        }
+        log.info("dinky app is Ready to run, config is {}", appConfig);
+        DBUtil.init(appConfig);
+        Submitter.submit(appConfig);
+        log.info("Start Monitor Job");
+        FlinkAppUtil.monitorFlinkTask(Submitter.executor, appConfig.getTaskId());
     }
 }
diff --git a/dinky-app/dinky-app-base/pom.xml b/dinky-app/dinky-app-base/pom.xml
@@ -40,6 +40,7 @@
         <dependency>
             <groupId>mysql</groupId>
             <artifactId>mysql-connector-java</artifactId>
+            <scope>provided</scope>
         </dependency>
         <dependency>
             <groupId>org.dinky</groupId>

diff --git a/dinky-gateway/src/main/java/org/dinky/gateway/kubernetes/KubernetesSessionGateway.java b/dinky-gateway/src/main/java/org/dinky/gateway/kubernetes/KubernetesSessionGateway.java
@@ -30,6 +30,9 @@
 import org.apache.flink.client.program.ClusterClient;
 import org.apache.flink.client.program.ClusterClientProvider;
 import org.apache.flink.kubernetes.KubernetesClusterDescriptor;
+import org.apache.flink.kubernetes.configuration.KubernetesConfigOptions;
+
+import cn.hutool.core.text.StrFormatter;
 
 /**
  * KubernetesSessionGateway
@@ -46,6 +49,8 @@ public GatewayType getType() {
     @Override
     public GatewayResult deployCluster(FlinkUdfPathContextHolder udfPathContextHolder) {
         if (Asserts.isNull(client)) {
+            String clusterId = StrFormatter.format("dinky-flink-session-{}", System.currentTimeMillis());
+            addConfigParas(KubernetesConfigOptions.CLUSTER_ID, clusterId);
             init();
         }