[kylin] branch kylin5 updated: KYLIN-5595 Launch Job Node not initialize spark session issue (#2127)

[xxyu]

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

xxyu pushed a commit to branch kylin5
in repository https://gitbox.apache.org/repos/asf/kylin.git


The following commit(s) were added to refs/heads/kylin5 by this push:
     new d11b664759 KYLIN-5595 Launch Job Node not initialize spark session 
issue (#2127)
d11b664759 is described below

commit d11b664759f7d85b7f5f29eaad00e220b66a1780
Author: Syleechan <38198463+syleec...@users.noreply.github.com>
AuthorDate: Fri Jun 30 14:23:10 2023 +0800

    KYLIN-5595 Launch Job Node not initialize spark session issue (#2127)
    
    * [KYLIN-5595] Launch Job Node not initialize spark session issue
    
    * [KYLIN-5595] Launch Job Node not initialize spark session issue
---
 .../org/apache/kylin/rest/config/AppInitializer.java    | 17 ++++++++---------
 1 file changed, 8 insertions(+), 9 deletions(-)

diff --git 
a/src/common-service/src/main/java/org/apache/kylin/rest/config/AppInitializer.java
 
b/src/common-service/src/main/java/org/apache/kylin/rest/config/AppInitializer.java
index c934e45bce..6fc2ff9e5d 100644
--- 
a/src/common-service/src/main/java/org/apache/kylin/rest/config/AppInitializer.java
+++ 
b/src/common-service/src/main/java/org/apache/kylin/rest/config/AppInitializer.java
@@ -133,15 +133,14 @@ public class AppInitializer {
         warmUpSystemCache();
         context.publishEvent(new AfterMetadataReadyEvent(context));
 
-        if (kylinConfig.isQueryNode()) {
-            if (kylinConfig.isSparderAsync()) {
-                context.publishEvent(new 
SparderStartEvent.AsyncEvent(context));
-            } else {
-                context.publishEvent(new SparderStartEvent.SyncEvent(context));
-            }
-            if (kylinConfig.isBloomCollectFilterEnabled()) {
-                QueryFiltersCollector.initScheduler();
-            }
+        if (kylinConfig.isSparderAsync()) {
+            context.publishEvent(new SparderStartEvent.AsyncEvent(context));
+        } else {
+            context.publishEvent(new SparderStartEvent.SyncEvent(context));
+        }
+
+        if (kylinConfig.isQueryNode() && 
kylinConfig.isBloomCollectFilterEnabled()) {
+            QueryFiltersCollector.initScheduler();
         }
         EventBusFactory.getInstance().register(new ProcessStatusListener(), 
true);
         // register acl update listener