topic How to specify/increase termination timeout in Alfresco Archive

How to specify/increase termination timeout

suribabu — Wed, 31 Oct 2012 13:39:36 GMT

Hi,I am new bee to Activiti BPM. When I am trying to start my process instance usingProcessInstance processInstance = runtimeService.startProcessInstanceByKey("process1",map);(this process includes many jobs run in parallel),the process is getting terminated after 60 seconds without completing all m

Re: How to specify/increase termination timeout

jbarrez — Fri, 02 Nov 2012 07:18:09 GMT

(this process includes many jobs run in parallel),

What do you mean with this? Does it have a lot of timers? Does it have many async steps?

Can you reproduce the issue in an easy unit test?

Re: How to specify/increase termination timeout

suribabu — Fri, 02 Nov 2012 12:24:46 GMT

Hi jbarrez,

It doesn't have timers but it has many async steps.
Here is the serviceTask configuration:

<serviceTask id="servicetask1" name="Process SubProj List" activiti:expression="${ProcessSubProjects.processSubProjects(cardSubProject,execution)}" activiti:async="true" activiti:exclusive="false">
<multiInstanceLoopCharacteristics isSequential="false" activiti:collection="CardSubProjectList" activiti:elementVariable="cardSubProject">
</multiInstanceLoopCharacteristics>
</serviceTask>

Thanks,
Suri.

Re: How to specify/increase termination timeout

jbarrez — Mon, 05 Nov 2012 08:00:27 GMT

On what database are you running on? Does your database use table locks? Because that's the only reason I can quickly think of that would generate timeouts.

Re: How to specify/increase termination timeout

frederikherema1 — Mon, 05 Nov 2012 11:09:33 GMT

If there are jobs with a duration that exceed that 60 seconds, these will be "killed" when the job-executor is requested to shut down and not finished within 60 seconds.

This is built in into the job executor. However, by extending and plugging in your own JobExecutor, you can later this behavior and have a longer wait-time or other behavior.

See src.main.java.org.activiti.engine.impl.jobexecutor.DefaultJobExecutor


 protected void stopExecutingJobs() {
    stopJobAcquisitionThread();
    
    // Ask the thread pool to finish and exit
    threadPoolExecutor.shutdown();

    // Waits for 1 minute to finish all currently executing jobs
    try {
      if(!threadPoolExecutor.awaitTermination(60L, TimeUnit.SECONDS)) {
        log.log(Level.WARNING, "Timeout during shutdown of job executor. "
                + "The current running jobs could not end within 60 seconds after shutdown operation.");        
      }              
    } catch (InterruptedException e) {
      log.log(Level.WARNING, "Interrupted while shutting down the job executor. ", e);
    }

    threadPoolExecutor = null;
  }