You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by do...@apache.org on 2022/08/26 08:47:46 UTC
[inlong] 01/02: [INLONG-5710][Audit] Fix the ClickHouse service initialization problem (#5711)
This is an automated email from the ASF dual-hosted git repository.
dockerzhang pushed a commit to branch release-1.3.0
in repository https://gitbox.apache.org/repos/asf/inlong.git
commit e02bef6c512a2a1f41c0263d36a3830cebf04358
Author: woofyzhao <49...@qq.com>
AuthorDate: Fri Aug 26 14:52:56 2022 +0800
[INLONG-5710][Audit] Fix the ClickHouse service initialization problem (#5711)
---
.../apache/inlong/audit/service/AuditMsgConsumerServer.java | 10 ++++++++--
1 file changed, 8 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 aa0acbf2d..f4f6af659 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
@@ -47,7 +47,9 @@ public class AuditMsgConsumerServer implements InitializingBean {
private StoreConfig storeConfig;
@Autowired
private ClickHouseConfig chConfig;
-
+ // ClickHouseService
+ private ClickHouseService ckService;
+
/**
* Initializing bean
*/
@@ -66,6 +68,10 @@ public class AuditMsgConsumerServer implements InitializingBean {
if (storeConfig.isElasticsearchStore()) {
esService.startTimerRoutine();
}
+ if (storeConfig.isClickHouseStore()) {
+ ckService = new ClickHouseService(chConfig);
+ ckService.start();
+ }
mqConsume.start();
}
@@ -82,7 +88,7 @@ public class AuditMsgConsumerServer implements InitializingBean {
insertServiceList.add(esService);
}
if (storeConfig.isClickHouseStore()) {
- insertServiceList.add(new ClickHouseService(chConfig));
+ insertServiceList.add(ckService);
}
return insertServiceList;
}