[incubator-streampark] branch dev updated: [Feature] Add id to ShutDownRequest (#3191)

[li...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

linying pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git


The following commit(s) were added to refs/heads/dev by this push:
     new 3b9abd3df [Feature] Add id to ShutDownRequest (#3191)
3b9abd3df is described below

commit 3b9abd3df145d2c722fc86390bddf7901cb4b0d0
Author: caicancai <77...@users.noreply.github.com>
AuthorDate: Tue Sep 26 20:43:57 2023 +0800

    [Feature] Add id to ShutDownRequest (#3191)
---
 .../streampark/console/core/service/impl/FlinkClusterServiceImpl.java    | 1 +
 .../scala/org/apache/streampark/flink/client/bean/ShutDownRequest.scala  | 1 +
 2 files changed, 2 insertions(+)

diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/FlinkClusterServiceImpl.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/FlinkClusterServiceImpl.java
index 275c08b05..57360757d 100644
--- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/FlinkClusterServiceImpl.java
+++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/FlinkClusterServiceImpl.java
@@ -421,6 +421,7 @@ public class FlinkClusterServiceImpl extends ServiceImpl<FlinkClusterMapper, Fli
             flinkCluster.getFlinkExecutionModeEnum(),
             flinkCluster.getProperties(),
             clusterId,
+            flinkCluster.getId(),
             getKubernetesDeployDesc(flinkCluster, "shutdown"));
     Future<ShutDownResponse> future =
         executorService.submit(() -> FlinkClient.shutdown(stopRequest));
diff --git a/streampark-flink/streampark-flink-client/streampark-flink-client-api/src/main/scala/org/apache/streampark/flink/client/bean/ShutDownRequest.scala b/streampark-flink/streampark-flink-client/streampark-flink-client-api/src/main/scala/org/apache/streampark/flink/client/bean/ShutDownRequest.scala
index 32d417527..08b54c2d1 100644
--- a/streampark-flink/streampark-flink-client/streampark-flink-client-api/src/main/scala/org/apache/streampark/flink/client/bean/ShutDownRequest.scala
+++ b/streampark-flink/streampark-flink-client/streampark-flink-client-api/src/main/scala/org/apache/streampark/flink/client/bean/ShutDownRequest.scala
@@ -29,4 +29,5 @@ case class ShutDownRequest(
     executionMode: FlinkExecutionMode,
     @Nullable properties: JavaMap[String, Any],
     clusterId: String,
+    id: Long,
     @Nullable kubernetesDeployParam: KubernetesDeployParam)