[incubator-streampark] branch dev updated: [Bug] app buildPipe state bug fixed (#2021)

[lvshaokang]

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

lvshaokang 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 5df6d9447 [Bug] app buildPipe state bug fixed (#2021)
5df6d9447 is described below

commit 5df6d944702226541f3b7f1276ff6e674bb5ad81
Author: benjobs <benj...@apache.org>
AuthorDate: Tue Nov 15 14:13:26 2022 +0800

    [Bug] app buildPipe state bug fixed (#2021)
---
 .../org/apache/streampark/console/core/entity/AppBuildPipeline.java  | 2 +-
 .../console/core/service/impl/AppBuildPipeServiceImpl.java           | 5 +++--
 2 files changed, 4 insertions(+), 3 deletions(-)

diff --git 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/AppBuildPipeline.java
 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/AppBuildPipeline.java
index 483c89039..ee1a9b38a 100644
--- 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/AppBuildPipeline.java
+++ 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/AppBuildPipeline.java
@@ -108,7 +108,7 @@ public class AppBuildPipeline {
 
     @Nonnull
     @JsonIgnore
-    public PipelineStatus getPipeStatus() {
+    public PipelineStatus getPipelineStatus() {
         return PipelineStatus.of(pipeStatusCode);
     }
 
diff --git 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/AppBuildPipeServiceImpl.java
 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/AppBuildPipeServiceImpl.java
index 96597b52e..95a2a09bb 100644
--- 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/AppBuildPipeServiceImpl.java
+++ 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/AppBuildPipeServiceImpl.java
@@ -435,7 +435,7 @@ public class AppBuildPipeServiceImpl
     @Override
     public boolean allowToBuildNow(@Nonnull Long appId) {
         return getCurrentBuildPipeline(appId)
-            .map(pipeline -> PipelineStatus.running != 
pipeline.getPipeStatus())
+            .map(pipeline -> PipelineStatus.running != 
pipeline.getPipelineStatus())
             .orElse(true);
     }
 
@@ -451,9 +451,10 @@ public class AppBuildPipeServiceImpl
         if (CollectionUtils.isEmpty(rMaps)) {
             return Maps.newHashMap();
         }
+
         return rMaps.stream().collect(Collectors.toMap(
             e -> (Long) e.get("app_id"),
-            e -> PipelineStatus.of((Integer) e.get("pipe_status"))));
+            e -> PipelineStatus.of((Integer) e.get("pipeStatusCode"))));
     }
 
     @Override