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

kerwin pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git


The following commit(s) were added to refs/heads/dev by this push:
     new d4d59b0  [FIX 6701] [API] Fix paging error when worker group number 
more than 10 (#6704)
d4d59b0 is described below

commit d4d59b0627237e73f6ca1762882938beee596e34
Author: ReonYu <[email protected]>
AuthorDate: Fri Nov 5 20:23:20 2021 +0800

    [FIX 6701] [API] Fix paging error when worker group number more than 10 
(#6704)
---
 .../dolphinscheduler/api/service/impl/WorkerGroupServiceImpl.java    | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git 
a/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/WorkerGroupServiceImpl.java
 
b/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/WorkerGroupServiceImpl.java
index 8124ed9..379af64 100644
--- 
a/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/WorkerGroupServiceImpl.java
+++ 
b/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/WorkerGroupServiceImpl.java
@@ -185,6 +185,7 @@ public class WorkerGroupServiceImpl extends BaseServiceImpl 
implements WorkerGro
 
         List<WorkerGroup> workerGroups = getWorkerGroups(true);
         List<WorkerGroup> resultDataList = new ArrayList<>();
+        int total = 0;
 
         if (CollectionUtils.isNotEmpty(workerGroups)) {
             List<WorkerGroup> searchValDataList = new ArrayList<>();
@@ -198,7 +199,7 @@ public class WorkerGroupServiceImpl extends BaseServiceImpl 
implements WorkerGro
             } else {
                 searchValDataList = workerGroups;
             }
-
+            total = searchValDataList.size();
             if (fromIndex < searchValDataList.size()) {
                 if (toIndex > searchValDataList.size()) {
                     toIndex = searchValDataList.size();
@@ -208,7 +209,7 @@ public class WorkerGroupServiceImpl extends BaseServiceImpl 
implements WorkerGro
         }
 
         PageInfo<WorkerGroup> pageInfo = new PageInfo<>(pageNo, pageSize);
-        pageInfo.setTotal(resultDataList.size());
+        pageInfo.setTotal(total);
         pageInfo.setTotalList(resultDataList);
 
         result.setData(pageInfo);

Reply via email to