sorry, I detail my question:
When the activiti engine stopped during executing a service task(I marked the service task as asynchronized). in the RU_JOB table, a job data will like below:
TYPE_="message", DUE_DATA_=null, RETRIES_>0(default=3), LOCK_OWNER_=null and LOCK_EXP_TIME_=<some time.
When I restart the activiti engine after the LOCK_EXP_TIME_ , the JOB could not be selected by the async job executor. That means this process instance is hang there forever.
But if I switch the async job executor to jobexecutor, when the current time is later than LOCK_EXP_TIME_, the the job could be selected out and execute.
I deep the code, and find the job select sql for async job executor is below:
<code>
<select id="selectNextTimerJobsToExecute" parameterType="org.activiti.engine.impl.db.ListQueryParameterObject" resultMap="jobResultMap">
${limitBefore}
select
RES.* ${limitBetween}
from ${prefix}ACT_RU_JOB RES
LEFT OUTER JOIN ${prefix}ACT_RU_EXECUTION PI ON PI.ID_ = RES.PROCESS_INSTANCE_ID_
where (RES.RETRIES_ > 0)
and (RES.DUEDATE_ is null or RES.DUEDATE_ <= #{parameter, jdbcType=TIMESTAMP})
and (RES.LOCK_OWNER_ is null or RES.LOCK_EXP_TIME_ <= #{parameter, jdbcType=TIMESTAMP})
and TYPE_ = 'timer'
and (
(RES.EXECUTION_ID_ is null)
or
(PI.SUSPENSION_STATE_ = 1)
)
${limitAfter}
</select>
<select id="selectAsyncJobsDueToExecute" parameterType="org.activiti.engine.impl.db.ListQueryParameterObject" resultMap="jobResultMap">
${limitBefore}
select
RES.* ${limitBetween}
from ${prefix}ACT_RU_JOB RES
LEFT OUTER JOIN ${prefix}ACT_RU_EXECUTION PI ON PI.ID_ = RES.PROCESS_INSTANCE_ID_
where RES.RETRIES_ > 0
and RES.DUEDATE_ is not null
and RES.DUEDATE_ <= #{parameter, jdbcType=TIMESTAMP}
and (RES.LOCK_EXP_TIME_ is null or RES.LOCK_EXP_TIME_ <= #{parameter, jdbcType=TIMESTAMP})
and TYPE_ = 'message'
and (
(RES.EXECUTION_ID_ is null)
or
(PI.SUSPENSION_STATE_ = 1)
)
${limitAfter}
</select>
</code>
and the sql for jobexecutor is below:
<code>
<select id="selectNextJobsToExecute" parameterType="org.activiti.engine.impl.db.ListQueryParameterObject" resultMap="jobResultMap">
${limitBefore}
select
RES.* ${limitBetween}
from ${prefix}ACT_RU_JOB RES
LEFT OUTER JOIN ${prefix}ACT_RU_EXECUTION PI ON PI.ID_ = RES.PROCESS_INSTANCE_ID_
where (RES.RETRIES_ > 0)
and (RES.DUEDATE_ is null or RES.DUEDATE_ <= #{parameter, jdbcType=TIMESTAMP})
and (RES.LOCK_OWNER_ is null or RES.LOCK_EXP_TIME_ <= #{parameter, jdbcType=TIMESTAMP})
and (
(RES.EXECUTION_ID_ is null)
or
(PI.SUSPENSION_STATE_ = 1)
)
${limitAfter}
</select>
</code>
So my question is why they are different, is there any reason for the async job executor not to select the expired job out?
