(incubator-streampark) branch dev-2.1.3 updated: [Improve] flink job on yarn exists check improve

[benjobs]

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

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


The following commit(s) were added to refs/heads/dev-2.1.3 by this push:
     new 9a2297a9a [Improve] flink job on yarn exists check improve
9a2297a9a is described below

commit 9a2297a9a27414ad78490b2f0778bcf3a4822285
Author: benjobs <benj...@gmail.com>
AuthorDate: Sat Dec 23 15:15:52 2023 +0800

    [Improve] flink job on yarn exists check improve
---
 .../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 3812e29c0..0dd23f526 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
@@ -640,7 +640,7 @@ public class ApplicationServiceImpl extends 
ServiceImpl<ApplicationMapper, Appli
 
   @Override
   public AppExistsState checkStart(Application appParam) {
-    Application application = getById(app.getId());
+    Application application = getById(appParam.getId());
     if (application == null) {
       return AppExistsState.INVALID;
     }