azkaban-aplcache

start the flow trigger service first then flow trigger scheduler

2/16/2018 9:16:14 PM

Details

diff --git a/azkaban-web-server/src/main/java/azkaban/webapp/AzkabanWebServer.java b/azkaban-web-server/src/main/java/azkaban/webapp/AzkabanWebServer.java
index 75a033c..52d831c 100644
--- a/azkaban-web-server/src/main/java/azkaban/webapp/AzkabanWebServer.java
+++ b/azkaban-web-server/src/main/java/azkaban/webapp/AzkabanWebServer.java
@@ -540,8 +540,12 @@ public class AzkabanWebServer extends AzkabanServer {
     }
 
     if (this.props.getBoolean(ConfigurationKeys.ENABLE_QUARTZ, false)) {
-      this.scheduler.start();
+      // flowTriggerService needs to be started first before scheduler starts to schedule
+      // existing flow triggers
+      logger.info("starting flow trigger service");
       this.flowTriggerService.start();
+      logger.info("starting flow trigger scheduler");
+      this.scheduler.start();
     }
 
     try {