[Bug] spark application mapping state bug fixed.

apache · Jan 17, 2025 · d67f0f6 · d67f0f6
1 parent 6b93948
commit d67f0f6
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...e/streampark/console/core/service/application/impl/SparkApplicationManageServiceImpl.java b/...e/streampark/console/core/service/application/impl/SparkApplicationManageServiceImpl.java
@@ -152,7 +152,7 @@ public void persistMetrics(SparkApplication appParam) {
 
     @Override
     public boolean mapping(SparkApplication appParam) {
-        this.lambdaUpdate()
+        return this.lambdaUpdate()
             .set(SparkApplication::getClusterId, appParam.getClusterId())
             .set(SparkApplication::getEndTime, null)
             .set(SparkApplication::getState, SparkAppStateEnum.MAPPING.getValue())