enhancement(flow): add heartbeat for flow task

[yhilmare]

What type of PR is this?

type-enhancement

What this PR does / why we need it:

ticket's status will not be changed when the odc node is crashed and there are flow task instance running on it and the user will find that the ticket will keep 'RUNNING' status without any changes.

I use heartbeat to solve this problem, the ticket will be cancelled if the related heartbeat is timeout

Which issue(s) this PR fixes:

Fixes #2476

Special notes for your reviewer:

Additional documentation e.g., usage docs, etc.:

[yizhouxw]

I didn't see the initial value of lastHeartbeatTime while task started, what is the behavior if lastHeatbeatTime is null ?

[yhilmare]

I didn't see the initial value of lastHeartbeatTime while task started, what is the behavior if lastHeatbeatTime is null ?

added, we will update heartbeat before task instance's status is updated to 'EXECUTING'

try {
                flowTaskInstance = getFlowTaskInstance(flowInstanceId, activityId);
                BaseRuntimeFlowableDelegate<?> delegate = getDelegateInstance(flowTaskInstance);
                // we init heartbeat time here
                delegate.updateHeartbeatTime();
                List<Class<? extends ExecutionListener>> list = delegate.getExecutionListenerClasses();
                if (CollectionUtils.isNotEmpty(list)) {
                    // we update flow task instance's status here, 'CREATED' -> 'EXECUTING'
                    list.forEach(c -> doCallListener(FlowConstants.EXECUTION_START_EVENT_NAME, executionFacade, c));
                }
                delegate.execute(executionFacade);
                ...
            } catch (Exception e) {
                ...
            } finally {
                ...
            }

[yhilmare]

I tested the performance with this data size:

SQL	duration	Return rows
select * from flow_instance_node_task where status='EXECUTING'	746.16ms	10w
select * from task_task where id in (?) and last_heartbeat_time < ?	703ms	5233
select * from flow_instance_node_task where status='EXECUTING' and id in (?) for update	90.89ms	2000
update flow_instance_node_task set status='CANCELLED' where id in (?)	51.85ms	2000
update flow_instance set status='CANCELLED' where id in (?)	9.67ms	130

[yizhouxw]

lgtm

[smallsheeeep]

LGTM

[MarkPotato777]

LGTM

[krihy]

LGTM