[incubator-streampark] branch mapping2 updated: [bug] Fix the problem that cannot be cancel after mapping

[monster]

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

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


The following commit(s) were added to refs/heads/mapping2 by this push:
     new efecb524f [bug] Fix the problem that cannot be cancel after mapping
efecb524f is described below

commit efecb524feca4009f754a5ca9562924f2279ec22
Author: Monster <2572805...@qq.com>
AuthorDate: Sat Nov 19 13:08:27 2022 +0800

    [bug] Fix the problem that cannot be cancel after mapping
---
 .../streampark/console/core/service/impl/ApplicationServiceImpl.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ApplicationServiceImpl.java
 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ApplicationServiceImpl.java
index 6eccd405c..1c58a46f0 100644
--- 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ApplicationServiceImpl.java
+++ 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ApplicationServiceImpl.java
@@ -1090,7 +1090,7 @@ public class ApplicationServiceImpl extends 
ServiceImpl<ApplicationMapper, Appli
         CancelRequest cancelRequest = new CancelRequest(
             flinkEnv.getFlinkVersion(),
             ExecutionMode.of(application.getExecutionMode()),
-            application.getAppId(),
+            application.getClusterId(),
             application.getJobId(),
             appParam.getSavePointed(),
             appParam.getDrain(),