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/06/04 02:03:01 UTC

[incubator-inlong] branch master updated: [INLONG-4497][Manager] Fix the method of asynchronously deleting the inlong group in the client (#4498)

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 20df23a0e [INLONG-4497][Manager] Fix the method of asynchronously deleting the inlong group in the client (#4498)
20df23a0e is described below

commit 20df23a0e77268a0634fbaf5b63d51cdc7d817ea
Author: kipshi <48...@users.noreply.github.com>
AuthorDate: Sat Jun 4 10:02:56 2022 +0800

    [INLONG-4497][Manager] Fix the method of asynchronously deleting the inlong group in the client (#4498)
---
 .../client/api/inner/InnerInlongManagerClient.java      | 17 +++++++++++------
 1 file changed, 11 insertions(+), 6 deletions(-)

diff --git a/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/inner/InnerInlongManagerClient.java b/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/inner/InnerInlongManagerClient.java
index 6d2c6bba5..fb4c870c7 100644
--- a/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/inner/InnerInlongManagerClient.java
+++ b/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/inner/InnerInlongManagerClient.java
@@ -533,15 +533,20 @@ public class InnerInlongManagerClient {
         String path = HTTP_PATH;
         if (async) {
             path += "/group/deleteAsync/" + groupId;
+            String finalGroupId = this.sendDeleteForClass(
+                    formatUrl(path),
+                    null,
+                    String.class
+            );
+            return groupId.equals(finalGroupId);
         } else {
             path += "/group/delete/" + groupId;
+            return this.sendDeleteForClass(
+                    formatUrl(path),
+                    null,
+                    Boolean.class
+            );
         }
-
-        return this.sendDeleteForClass(
-                formatUrl(path),
-                null,
-                Boolean.class
-        );
     }
 
     /**