(incubator-streampark) branch dev-2.1.5 updated: [Improve] flink cluster API minor improvement

[benjobs]

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

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


The following commit(s) were added to refs/heads/dev-2.1.5 by this push:
     new ff4f97b40 [Improve] flink cluster API minor improvement
ff4f97b40 is described below

commit ff4f97b40cde1525463d656deb390f712e0e4707
Author: benjobs <benj...@apache.org>
AuthorDate: Mon Sep 2 20:33:36 2024 +0800

    [Improve] flink cluster API minor improvement
---
 .../streampark/console/core/controller/FlinkClusterController.java  | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/FlinkClusterController.java
 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/FlinkClusterController.java
index eca8eccbd..dc522ec10 100644
--- 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/FlinkClusterController.java
+++ 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/FlinkClusterController.java
@@ -35,6 +35,8 @@ import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
+import java.util.List;
+
 @Slf4j
 @Validated
 @RestController
@@ -52,8 +54,8 @@ public class FlinkClusterController {
   }
 
   @PostMapping("list")
-  public RestResponse list(FlinkCluster flinkCluster, RestRequest restRequest) 
{
-    IPage<FlinkCluster> flinkClusters = 
flinkClusterService.findPage(flinkCluster, restRequest);
+  public RestResponse list() {
+    List<FlinkCluster> flinkClusters = flinkClusterService.listCluster();
     return RestResponse.success(flinkClusters);
   }