public void startTrigger(final FlowTrigger flowTrigger, final String flowId,
      final int flowVersion, final String submitUser, final Project project) {
    final TriggerInstance triggerInst = createTriggerInstance(flowTrigger, flowId, flowVersion,
        submitUser, project);
    this.flowTriggerExecutorService.submit(() -> {
      logger.info("Starting the flow trigger [trigger instance id: {}] by {}",
          triggerInst.getId(), submitUser);
      start(triggerInst);
    });
  }
public void startTrigger ( final FlowTrigger flowTrigger , final String flowId , final int flowVersion , final String submitUser , final Project project ) { final TriggerInstance triggerInst = createTriggerInstance ( flowTrigger , flowId , flowVersion , submitUser , project ) ; this . flowTriggerExecutorService . submit ( ( ) -> { logger . info ( "Starting the flow trigger [trigger instance id: {}] by {}" , triggerInst . getId ( ) , submitUser ) ; start ( triggerInst ) ; } ) ; }
Start the trigger. The method will be scheduled to invoke by azkaban scheduler.