(incubator-streampark) branch k8s-shutdown updated: [Improve] k8s shutdown improvement

[benjobs]

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

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


The following commit(s) were added to refs/heads/k8s-shutdown by this push:
     new a55267d1d [Improve] k8s shutdown improvement
a55267d1d is described below

commit a55267d1db0891b0f4e21c7ff64364e8785a51ae
Author: benjobs <benj...@gmail.com>
AuthorDate: Tue Jan 9 21:39:06 2024 +0800

    [Improve] k8s shutdown improvement
---
 .../src/main/scala/org/apache/streampark/flink/client/FlinkClient.scala | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/streampark-flink/streampark-flink-client/streampark-flink-client-api/src/main/scala/org/apache/streampark/flink/client/FlinkClient.scala
 
b/streampark-flink/streampark-flink-client/streampark-flink-client-api/src/main/scala/org/apache/streampark/flink/client/FlinkClient.scala
index 19ee9e744..3c7c65dcb 100644
--- 
a/streampark-flink/streampark-flink-client/streampark-flink-client-api/src/main/scala/org/apache/streampark/flink/client/FlinkClient.scala
+++ 
b/streampark-flink/streampark-flink-client/streampark-flink-client-api/src/main/scala/org/apache/streampark/flink/client/FlinkClient.scala
@@ -40,7 +40,7 @@ object FlinkClient extends Logger {
     "org.apache.streampark.flink.client.bean.CancelRequest" -> "cancel"
 
   private[this] val SHUTDOWN_REQUEST =
-    "org.apache.streampark.flink.client.bean.ShutDownRequest" -> "shutdown"
+    "org.apache.streampark.flink.client.bean.DeployRequest" -> "shutdown"
 
   private[this] val SAVEPOINT_REQUEST =
     "org.apache.streampark.flink.client.bean.TriggerSavepointRequest" -> 
"triggerSavepoint"