[inlong] 01/02: [INLONG-5710][Audit] Fix the ClickHouse service initialization problem (#5711)

[dockerzhang]

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 <490467...@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;
     }