DM subtask stage shows running but in fact it's paused

[lance6716]

What did you do?

https://ci2.pingcap.net/blue/organizations/jenkins/dm_ghpr_integration_test/detail/dm_ghpr_integration_test/10575/pipeline/

tiflow/dm/worker/subtask.go

Lines 640 to 643 in d88be9f

	go st.fetchResultAndUpdateStage(pr)
	go cu.Resume(ctx, pr)
	st.setStageAndResult(pb.Stage_Running, nil) // clear previous result

there's a "set stage to paused" in fetchResultAndUpdateStage of line 640, it will race with st.setStageAndResult(pb.Stage_Running, nil) in line 643.

What did you expect to see?

No response

What did you see instead?

No response

Versions of the cluster

DM version (run dmctl -V or dm-worker -V or dm-master -V):

(paste DM version here, and you must ensure versions of dmctl, DM-worker and DM-master are same)

Upstream MySQL/MariaDB server version:

(paste upstream MySQL/MariaDB server version here)

Downstream TiDB cluster version (execute SELECT tidb_version(); in a MySQL client):

(paste TiDB cluster version here)

How did you deploy DM: tiup or manually?

(leave TiUP or manually here)

Other interesting information (system version, hardware config, etc):

>
>

current status of DM cluster (execute query-status <task-name> in dmctl)

(paste current status of DM cluster here)