You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by do...@apache.org on 2022/04/16 16:43:40 UTC
[incubator-inlong] branch master updated: [INLONG-3769][Manager] Fix the bug of failing to run list group (#3770)
This is an automated email from the ASF dual-hosted git repository.
dockerzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git
The following commit(s) were added to refs/heads/master by this push:
new 78f1a50b8 [INLONG-3769][Manager] Fix the bug of failing to run list group (#3770)
78f1a50b8 is described below
commit 78f1a50b89350ca4de3bd0713b77707acb08b26a
Author: haifxu <xh...@gmail.com>
AuthorDate: Sun Apr 17 00:43:35 2022 +0800
[INLONG-3769][Manager] Fix the bug of failing to run list group (#3770)
---
.../org/apache/inlong/manager/client/cli/CommandList.java | 14 ++++++++++----
.../inlong/manager/client/cli/enums/InlongGroupState.java | 1 -
2 files changed, 10 insertions(+), 5 deletions(-)
diff --git a/inlong-manager/manager-client-tools/src/main/java/org/apache/inlong/manager/client/cli/CommandList.java b/inlong-manager/manager-client-tools/src/main/java/org/apache/inlong/manager/client/cli/CommandList.java
index 4244408fc..e6b689227 100644
--- a/inlong-manager/manager-client-tools/src/main/java/org/apache/inlong/manager/client/cli/CommandList.java
+++ b/inlong-manager/manager-client-tools/src/main/java/org/apache/inlong/manager/client/cli/CommandList.java
@@ -93,13 +93,19 @@ public class CommandList extends CommandBase {
@Override
void run() {
try {
- List<Integer> stateList = InlongGroupState.parseStatus(status);
InnerInlongManagerClient managerClient = new InnerInlongManagerClient(connect().getConfiguration());
List<InlongGroupListResponse> groupList = new ArrayList<>();
- for (int state : stateList) {
- PageInfo<InlongGroupListResponse> groupPageInfo = managerClient.listGroups(group, state, 1,
+ if (status != null) {
+ List<Integer> stateList = InlongGroupState.parseStatus(status);
+ for (int state : stateList) {
+ PageInfo<InlongGroupListResponse> groupPageInfo = managerClient.listGroups(group, state, 1,
+ pageSize);
+ groupList.addAll(groupPageInfo.getList());
+ }
+ } else {
+ PageInfo<InlongGroupListResponse> groupPageInfo = managerClient.listGroups(group, 0, 1,
pageSize);
- groupList.addAll(groupPageInfo.getList());
+ groupList = groupPageInfo.getList();
}
PrintUtil.print(groupList, GroupInfo.class);
} catch (Exception e) {
diff --git a/inlong-manager/manager-client-tools/src/main/java/org/apache/inlong/manager/client/cli/enums/InlongGroupState.java b/inlong-manager/manager-client-tools/src/main/java/org/apache/inlong/manager/client/cli/enums/InlongGroupState.java
index 63bc8dd04..786a5ae81 100644
--- a/inlong-manager/manager-client-tools/src/main/java/org/apache/inlong/manager/client/cli/enums/InlongGroupState.java
+++ b/inlong-manager/manager-client-tools/src/main/java/org/apache/inlong/manager/client/cli/enums/InlongGroupState.java
@@ -38,7 +38,6 @@ public enum InlongGroupState {
switch (groupState) {
case CREATE:
stateList.add(GroupState.DRAFT.getCode());
- stateList.add(GroupState.TO_BE_SUBMIT.getCode());
return stateList;
case OPERATING:
stateList.add(GroupState.DELETING.getCode());