[Feature] Add id to ShutDownRequest (#3191)

apache · Sep 26, 2023 · 3b9abd3 · 3b9abd3
1 parent 49a16e7
commit 3b9abd3
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 0 deletions.
diff --git a/...rc/main/java/org/apache/streampark/console/core/service/impl/FlinkClusterServiceImpl.java b/...rc/main/java/org/apache/streampark/console/core/service/impl/FlinkClusterServiceImpl.java
@@ -421,6 +421,7 @@ private ShutDownResponse shutdownInternal(FlinkCluster flinkCluster, String clus
             flinkCluster.getFlinkExecutionModeEnum(),
             flinkCluster.getProperties(),
             clusterId,
+            flinkCluster.getId(),
             getKubernetesDeployDesc(flinkCluster, "shutdown"));
     Future<ShutDownResponse> future =
         executorService.submit(() -> FlinkClient.shutdown(stopRequest));

diff --git a/...k-client-api/src/main/scala/org/apache/streampark/flink/client/bean/ShutDownRequest.scala b/...k-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)