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

healchow 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 1ae83c3d8 [INLONG-4687][Manager] Add middlewareType field back to 
adapt the old behavior (#4689)
1ae83c3d8 is described below

commit 1ae83c3d89a7fda126fcc54034fb8acec81d3557
Author: kipshi <[email protected]>
AuthorDate: Fri Jun 17 15:37:17 2022 +0800

    [INLONG-4687][Manager] Add middlewareType field back to adapt the old 
behavior (#4689)
---
 .../main/java/org/apache/inlong/manager/common/enums/GroupStatus.java | 3 ++-
 .../org/apache/inlong/manager/common/pojo/group/InlongGroupInfo.java  | 4 ++++
 .../apache/inlong/manager/common/pojo/group/InlongGroupRequest.java   | 4 ++++
 3 files changed, 10 insertions(+), 1 deletion(-)

diff --git 
a/inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/enums/GroupStatus.java
 
b/inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/enums/GroupStatus.java
index da790561d..d42ed9bde 100644
--- 
a/inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/enums/GroupStatus.java
+++ 
b/inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/enums/GroupStatus.java
@@ -125,7 +125,8 @@ public enum GroupStatus {
      * allows change the MQ type of inlong group.
      */
     public static boolean notAllowedUpdateMQ(GroupStatus status) {
-        return status == GroupStatus.DRAFT || status == 
GroupStatus.TO_BE_SUBMIT;
+        return status != GroupStatus.DRAFT && status != 
GroupStatus.TO_BE_SUBMIT
+                && status != GroupStatus.APPROVE_REJECTED && status != 
GroupStatus.CONFIG_FAILED;
     }
 
     /**
diff --git 
a/inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/group/InlongGroupInfo.java
 
b/inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/group/InlongGroupInfo.java
index 6ea1436cf..2bb4f4468 100644
--- 
a/inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/group/InlongGroupInfo.java
+++ 
b/inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/group/InlongGroupInfo.java
@@ -56,6 +56,10 @@ public abstract class InlongGroupInfo {
     @ApiModelProperty(value = "Inlong group description")
     private String description;
 
+    @Deprecated
+    @ApiModelProperty(value = "MQ type, replaced by mqType")
+    private String middlewareType;
+
     @ApiModelProperty(value = "MQ type, high throughput: TUBE, high 
consistency: PULSAR")
     private String mqType;
 
diff --git 
a/inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/group/InlongGroupRequest.java
 
b/inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/group/InlongGroupRequest.java
index 1abe3ae8a..aee78b58b 100644
--- 
a/inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/group/InlongGroupRequest.java
+++ 
b/inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/group/InlongGroupRequest.java
@@ -58,6 +58,10 @@ public class InlongGroupRequest {
     @ApiModelProperty(value = "Inlong group description")
     private String description;
 
+    @Deprecated
+    @ApiModelProperty(value = "MQ type, replaced by mqType")
+    private String middlewareType;
+
     @NotBlank
     @ApiModelProperty(value = "MQ type, high throughput: TUBE, high 
consistency: PULSAR")
     private String mqType;

Reply via email to