diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/SparkClusterServiceImpl.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/SparkClusterServiceImpl.java
index 35ff96ec1d..202c44fbab 100644
--- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/SparkClusterServiceImpl.java
+++ b/streampark-console/streampark-console-service/src/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