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

gosonzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git


The following commit(s) were added to refs/heads/master by this push:
     new 460ec7d0a [INLONG-6610][Manager] Support the saving and query of data 
report-to settings (addendum) (#6701)
460ec7d0a is described below

commit 460ec7d0a1f4e111eb7762563a3f0892cd5308ea
Author: Goson Zhang <[email protected]>
AuthorDate: Fri Dec 2 14:11:27 2022 +0800

    [INLONG-6610][Manager] Support the saving and query of data report-to 
settings (addendum) (#6701)
---
 .../apache/inlong/manager/service/group/InlongGroupServiceImpl.java   | 4 ++++
 1 file changed, 4 insertions(+)

diff --git 
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/group/InlongGroupServiceImpl.java
 
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/group/InlongGroupServiceImpl.java
index 0c2ed8588..2f7ced7e4 100644
--- 
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/group/InlongGroupServiceImpl.java
+++ 
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/group/InlongGroupServiceImpl.java
@@ -382,6 +382,10 @@ public class InlongGroupServiceImpl implements 
InlongGroupService {
             entity.setInlongGroupId(groupId);
             entity.setInlongClusterTag(approveRequest.getInlongClusterTag());
             entity.setStatus(GroupStatus.APPROVE_PASSED.getCode());
+            if (approveRequest.getDataReportType() != null
+                    && !Objects.equals(approveRequest.getDataReportType(), 
entity.getDataReportType())) {
+                entity.setDataReportType(approveRequest.getDataReportType());
+            }
             entity.setModifier(operator);
             int rowCount = groupMapper.updateByIdentifierSelective(entity);
             if (rowCount != InlongConstants.AFFECTED_ONE_ROW) {

Reply via email to