[incubator-inlong] branch master updated: [INLONG-4532][Manager] Fix init the sort config error in the client (#4533)

[healchow]

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 9ad1bc8c6 [INLONG-4532][Manager] Fix init the sort config error in the 
client (#4533)
9ad1bc8c6 is described below

commit 9ad1bc8c6d23b128f5b2a9465371fd1852018dee
Author: kipshi <48468934+kip...@users.noreply.github.com>
AuthorDate: Mon Jun 6 22:31:33 2022 +0800

    [INLONG-4532][Manager] Fix init the sort config error in the client (#4533)
---
 .../org/apache/inlong/manager/client/api/impl/InlongGroupImpl.java    | 2 ++
 .../apache/inlong/manager/client/api/util/InlongGroupTransfer.java    | 4 ++++
 2 files changed, 6 insertions(+)

diff --git 
a/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/impl/InlongGroupImpl.java
 
b/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/impl/InlongGroupImpl.java
index 388745684..3472b7141 100644
--- 
a/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/impl/InlongGroupImpl.java
+++ 
b/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/impl/InlongGroupImpl.java
@@ -71,6 +71,8 @@ public class InlongGroupImpl implements InlongGroup {
         if (newGroupInfo != null) {
             this.groupContext.setGroupInfo(groupInfo);
         } else {
+            BaseSortConf sortConf = groupInfo.getSortConf();
+            groupInfo = InlongGroupTransfer.createGroupInfo(groupInfo, 
sortConf);
             String groupId = managerClient.createGroup(groupInfo.genRequest());
             groupInfo.setInlongGroupId(groupId);
         }
diff --git 
a/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/util/InlongGroupTransfer.java
 
b/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/util/InlongGroupTransfer.java
index 4efb42a6b..26a604e1f 100644
--- 
a/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/util/InlongGroupTransfer.java
+++ 
b/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/util/InlongGroupTransfer.java
@@ -72,6 +72,10 @@ public class InlongGroupTransfer {
             originGroupInfo.getExtList().addAll(extInfos);
         }
 
+        if (sortConf == null) {
+            throw new IllegalArgumentException(
+                    String.format("sort config cannot be empty for group=", 
originGroupInfo.getInlongGroupId()));
+        }
         // set the sort config into ext list
         SortType sortType = sortConf.getType();
         List<InlongGroupExtInfo> sortExtInfos;