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 03:37:15 UTC
[incubator-inlong] branch master updated: [INLONG-1975][Bug]error occurs when delete a data access (#1976)
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 1708020 [INLONG-1975][Bug]error occurs when delete a data access (#1976)
1708020 is described below
commit 17080203524207d7dc0cb9a368817ee281fb5994
Author: healchow <he...@gmail.com>
AuthorDate: Tue Dec 14 11:33:07 2021 +0800
[INLONG-1975][Bug]error occurs when delete a data access (#1976)
Co-authored-by: healchow <he...@gmail.com>
---
.../src/main/resources/mappers/BusinessPulsarEntityMapper.xml | 2 +-
.../apache/inlong/manager/service/core/impl/DataStreamServiceImpl.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/inlong-manager/manager-dao/src/main/resources/mappers/BusinessPulsarEntityMapper.xml b/inlong-manager/manager-dao/src/main/resources/mappers/BusinessPulsarEntityMapper.xml
index f2c4de8..88d0f0b 100644
--- a/inlong-manager/manager-dao/src/main/resources/mappers/BusinessPulsarEntityMapper.xml
+++ b/inlong-manager/manager-dao/src/main/resources/mappers/BusinessPulsarEntityMapper.xml
@@ -62,7 +62,7 @@
<update id="logicDeleteByGroupId">
update business_pulsar
set is_deleted = 1
- where inlong_group_id = #{inlongGroupId, jdbcType=VARCHAR}
+ where inlong_group_id = #{groupId, jdbcType=VARCHAR}
and is_deleted = 0
</update>
diff --git a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/DataStreamServiceImpl.java b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/DataStreamServiceImpl.java
index 8e30a74..c3d8d37 100644
--- a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/DataStreamServiceImpl.java
+++ b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/DataStreamServiceImpl.java
@@ -565,7 +565,7 @@ public class DataStreamServiceImpl implements DataStreamService {
@Override
public int selectCountByGroupId(String groupId) {
- LOGGER.debug("begin bo get count by groupId={}", groupId);
+ LOGGER.debug("begin to get count by groupId={}", groupId);
if (StringUtils.isEmpty(groupId)) {
return 0;
}