[Feature] support spark standalone deploy mode

apache · Dec 1, 2024 · 6d6bb64 · 6d6bb64
1 parent 954f63b
commit 6d6bb64
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/...rc/main/java/org/apache/streampark/console/core/service/impl/SparkClusterServiceImpl.java b/...rc/main/java/org/apache/streampark/console/core/service/impl/SparkClusterServiceImpl.java
@@ -65,9 +65,7 @@ public class SparkClusterServiceImpl extends ServiceImpl<SparkClusterMapper, Spa
 
     @Override
     public List<SparkCluster> listAvailableCluster() {
-        LambdaQueryWrapper<SparkCluster> lambdaQueryWrapper = new LambdaQueryWrapper<>();
-        lambdaQueryWrapper.eq(SparkCluster::getClusterState, ClusterState.RUNNING.getState());
-        return this.list(lambdaQueryWrapper);
+        return this.lambdaQuery().eq(SparkCluster::getClusterState, ClusterState.RUNNING.getState()).list();
     }
 
     @Override