You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by go...@apache.org on 2021/12/14 10:25:50 UTC
[incubator-inlong] branch master updated: [INLONG-1984][Bug][InLong-Manager] Create pulsar access, modify pulsar related parameters failed (#1985)
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/incubator-inlong.git
The following commit(s) were added to refs/heads/master by this push:
new d96da15 [INLONG-1984][Bug][InLong-Manager] Create pulsar access, modify pulsar related parameters failed (#1985)
d96da15 is described below
commit d96da1533a705fd41ae3c9de05530273c3adbbf9
Author: healchow <he...@gmail.com>
AuthorDate: Tue Dec 14 18:25:46 2021 +0800
[INLONG-1984][Bug][InLong-Manager] Create pulsar access, modify pulsar related parameters failed (#1985)
Co-authored-by: healchow <he...@gmail.com>
---
.../org/apache/inlong/manager/service/core/impl/BusinessServiceImpl.java | 1 +
1 file changed, 1 insertion(+)
diff --git a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/BusinessServiceImpl.java b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/BusinessServiceImpl.java
index ba64f16..479e1b9 100644
--- a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/BusinessServiceImpl.java
+++ b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/BusinessServiceImpl.java
@@ -237,6 +237,7 @@ public class BusinessServiceImpl implements BusinessService {
"Pulsar params must meet: ackQuorum <= writeQuorum");
}
BusinessPulsarEntity pulsarEntity = CommonBeanUtils.copyProperties(pulsarInfo, BusinessPulsarEntity::new);
+ pulsarEntity.setInlongGroupId(groupId);
businessPulsarMapper.updateByIdentifierSelective(pulsarEntity);
}