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 2022/09/30 03:20:30 UTC
[inlong] branch master updated: [INLONG-6069][Audit] Initializing the ClickHouse service before its starts (#6070)
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 12f61c6a1 [INLONG-6069][Audit] Initializing the ClickHouse service before its starts (#6070)
12f61c6a1 is described below
commit 12f61c6a1234a629ccbd2efbe1d49da2af607b3b
Author: Goson Zhang <46...@qq.com>
AuthorDate: Fri Sep 30 11:20:25 2022 +0800
[INLONG-6069][Audit] Initializing the ClickHouse service before its starts (#6070)
---
.../java/org/apache/inlong/audit/service/AuditMsgConsumerServer.java | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
diff --git a/inlong-audit/audit-store/src/main/java/org/apache/inlong/audit/service/AuditMsgConsumerServer.java b/inlong-audit/audit-store/src/main/java/org/apache/inlong/audit/service/AuditMsgConsumerServer.java
index f4f6af659..502eab325 100644
--- a/inlong-audit/audit-store/src/main/java/org/apache/inlong/audit/service/AuditMsgConsumerServer.java
+++ b/inlong-audit/audit-store/src/main/java/org/apache/inlong/audit/service/AuditMsgConsumerServer.java
@@ -49,7 +49,7 @@ public class AuditMsgConsumerServer implements InitializingBean {
private ClickHouseConfig chConfig;
// ClickHouseService
private ClickHouseService ckService;
-
+
/**
* Initializing bean
*/
@@ -69,7 +69,6 @@ public class AuditMsgConsumerServer implements InitializingBean {
esService.startTimerRoutine();
}
if (storeConfig.isClickHouseStore()) {
- ckService = new ClickHouseService(chConfig);
ckService.start();
}
mqConsume.start();
@@ -88,6 +87,8 @@ public class AuditMsgConsumerServer implements InitializingBean {
insertServiceList.add(esService);
}
if (storeConfig.isClickHouseStore()) {
+ // create ck object
+ ckService = new ClickHouseService(chConfig);
insertServiceList.add(ckService);
}
return insertServiceList;