[inlong] branch release-1.3.0 updated: [INLONG-6069][Audit] Initializing the ClickHouse service before its starts (#6070)

[gosonzhang]

This is an automated email from the ASF dual-hosted git repository.

gosonzhang pushed a commit to branch release-1.3.0
in repository https://gitbox.apache.org/repos/asf/inlong.git


The following commit(s) were added to refs/heads/release-1.3.0 by this push:
     new 8182772f1 [INLONG-6069][Audit] Initializing the ClickHouse service 
before its starts (#6070)
8182772f1 is described below

commit 8182772f19875f78337f9fc81261477558d51d48
Author: Goson Zhang <4675...@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;