[Feature][scaleph-ui-react] update flink sql online editor

.gitignore

@@ -3,6 +3,7 @@ target/
 .mvn/wrapper/maven-wrapper.jar
 !**/src/main/**/target/
 !**/src/test/**/target/
+/node_modules
 
 ### STS ###
 .apt_generated

index.d.ts

@@ -0,0 +1,5 @@
+declare module 'monaco-editor/esm/vs/basic-languages/sql/sql';
+declare module 'monaco-editor/esm/vs/language/typescript/ts.worker.js';
+declare module 'monaco-editor/esm/vs/editor/editor.worker.js';
+declare module 'monaco-editor/esm/vs/language/sql/monaco.contribution'
+declare module 'monaco-editor/esm/vs/editor/editor.worker'

package.json

@@ -0,0 +1,6 @@
+{
+  "dependencies": {
+    "monaco-editor": "^0.40.0",
+    "sql-formatter": "^12.2.4"
+  }
+}

pom.xml

@@ -101,7 +101,6 @@
         <module>scaleph-workflow</module>
         <module>scaleph-datasource</module>
         <module>scaleph-kubernetes</module>
-        <module>scaleph-catalog</module>
 
         <module>scaleph-dist</module>
         <module>scaleph-file-fetcher</module>
@@ -161,6 +160,9 @@
         <protobuf.version>3.21.5</protobuf.version>
         <netty.version>4.1.82.Final</netty.version>
         <flink.version>1.17.1</flink.version>
+        <flink.base.version>1.17</flink.base.version>
+        <flink-jdbc.version>3.1.1</flink-jdbc.version>
+        <paimon.version>0.4.0-incubating</paimon.version>
         <kubernetes.client.version>6.2.0</kubernetes.client.version>
         <spring-cloud-openfeign.version>3.1.7</spring-cloud-openfeign.version>
         <zjsonpatch.version>0.4.14</zjsonpatch.version>
@@ -249,11 +251,6 @@
                 <artifactId>scaleph-meta</artifactId>
                 <version>${project.version}</version>
             </dependency>
-            <dependency>
-                <groupId>${project.groupId}</groupId>
-                <artifactId>scaleph-catalog</artifactId>
-                <version>${project.version}</version>
-            </dependency>
             <dependency>
                 <groupId>${project.groupId}</groupId>
                 <artifactId>scaleph-project</artifactId>
@@ -551,10 +548,21 @@
             </dependency>
             <dependency>
                 <groupId>org.apache.flink</groupId>
-                <artifactId>flink-table-planner_2.12</artifactId>
+                <artifactId>flink-table-planner-loader</artifactId>
                 <version>${flink.version}</version>
             </dependency>
 
+            <dependency>
+                <groupId>org.apache.flink</groupId>
+                <artifactId>flink-connector-jdbc</artifactId>
+                <version>${flink-jdbc.version}-${flink.base.version}</version>
+            </dependency>
+            <dependency>
+                <groupId>org.apache.paimon</groupId>
+                <artifactId>paimon-flink-1.17</artifactId>
+                <version>${paimon.version}</version>
+            </dependency>
+
             <dependency>
                 <groupId>org.apache.flink</groupId>
                 <artifactId>flink-kubernetes</artifactId>

scaleph-api/src/main/java/cn/sliew/scaleph/api/controller/ws/WsFlinkKubernetesJobController.java

@@ -130,6 +130,38 @@ public ResponseEntity<ResponseVO> shutdown(@Valid @RequestBody WsFlinkKubernetes
         return new ResponseEntity<>(ResponseVO.success(), HttpStatus.OK);
     }
 
+    @Logging
+    @PostMapping("restart/{id}")
+    @Operation(summary = "重启 Job", description = "重启 Job")
+    public ResponseEntity<ResponseVO> restart(@PathVariable("id") Long id) throws Exception {
+        wsFlinkKubernetesJobInstanceService.restart(id);
+        return new ResponseEntity<>(ResponseVO.success(), HttpStatus.OK);
+    }
+
+    @Logging
+    @PostMapping("triggerSavepoint/{id}")
+    @Operation(summary = "为 Job 创建 savepoint", description = "为 Job 创建 savepoint")
+    public ResponseEntity<ResponseVO> triggerSavepoint(@PathVariable("id") Long id) throws Exception {
+        wsFlinkKubernetesJobInstanceService.triggerSavepoint(id);
+        return new ResponseEntity<>(ResponseVO.success(), HttpStatus.OK);
+    }
+
+    @Logging
+    @PostMapping("suspend/{id}")
+    @Operation(summary = "暂停 Job", description = "暂停 Job")
+    public ResponseEntity<ResponseVO> suspend(@PathVariable("id") Long id) throws Exception {
+        wsFlinkKubernetesJobInstanceService.suspend(id);
+        return new ResponseEntity<>(ResponseVO.success(), HttpStatus.OK);
+    }
+
+    @Logging
+    @PostMapping("resume/{id}")
+    @Operation(summary = "恢复 Job", description = "恢复 Job")
+    public ResponseEntity<ResponseVO> resume(@PathVariable("id") Long id) throws Exception {
+        wsFlinkKubernetesJobInstanceService.resume(id);
+        return new ResponseEntity<>(ResponseVO.success(), HttpStatus.OK);
+    }
+
     @Logging
     @GetMapping("instances")
     @Operation(summary = "获取任务实例列表", description = "获取任务实例列表")