data race of Start/Close of DM-worker's Server

[lance6716]

What did you do?

[2022-07-21T02:26:46.380Z] WARNING: DATA RACE

[2022-07-21T02:26:46.380Z] Write at 0x00c000888810 by goroutine 94:

[2022-07-21T02:26:46.380Z]   github.com/pingcap/tiflow/dm/worker.(*Server).Start.func1()

[2022-07-21T02:26:46.380Z]       /home/jenkins/agent/workspace/dm_ghpr_integration_test/go/src/github.com/pingcap/tiflow/dm/worker/server.go:130 +0x6ee

[2022-07-21T02:26:46.380Z]   github.com/pingcap/tiflow/dm/worker.(*Server).Start()

[2022-07-21T02:26:46.380Z]       /home/jenkins/agent/workspace/dm_ghpr_integration_test/go/src/github.com/pingcap/tiflow/dm/worker/server.go:241 +0xa4

[2022-07-21T02:26:46.380Z]   github.com/pingcap/tiflow/cmd/dm-worker.main()

[2022-07-21T02:26:46.380Z]       /home/jenkins/agent/workspace/dm_ghpr_integration_test/go/src/github.com/pingcap/tiflow/cmd/dm-worker/main.go:93 +0x944

[2022-07-21T02:26:46.380Z]   github.com/pingcap/tiflow/cmd/dm-worker.TestRunMain.func3()

[2022-07-21T02:26:46.380Z]       /home/jenkins/agent/workspace/dm_ghpr_integration_test/go/src/github.com/pingcap/tiflow/cmd/dm-worker/main_test.go:66 +0x2b

[2022-07-21T02:26:46.380Z] 

[2022-07-21T02:26:46.380Z] Previous read at 0x00c000888810 by goroutine 104:

[2022-07-21T02:26:46.380Z]   github.com/pingcap/tiflow/dm/worker.(*Server).Close()

[2022-07-21T02:26:46.380Z]       /home/jenkins/agent/workspace/dm_ghpr_integration_test/go/src/github.com/pingcap/tiflow/dm/worker/server.go:496 +0x64

[2022-07-21T02:26:46.380Z]   github.com/pingcap/tiflow/cmd/dm-worker.main.func2()

[2022-07-21T02:26:46.380Z]       /home/jenkins/agent/workspace/dm_ghpr_integration_test/go/src/github.com/pingcap/tiflow/cmd/dm-worker/main.go:91 +0x1b7

[2022-07-21T02:26:46.380Z] 

[2022-07-21T02:26:46.380Z] Goroutine 94 (running) created at:

[2022-07-21T02:26:46.380Z]   github.com/pingcap/tiflow/cmd/dm-worker.TestRunMain()

[2022-07-21T02:26:46.380Z]       /home/jenkins/agent/workspace/dm_ghpr_integration_test/go/src/github.com/pingcap/tiflow/cmd/dm-worker/main_test.go:65 +0x331

[2022-07-21T02:26:46.380Z]   testing.tRunner()

[2022-07-21T02:26:46.380Z]       /usr/local/go/src/testing/testing.go:1439 +0x213

[2022-07-21T02:26:46.380Z]   testing.(*T).Run.func1()

[2022-07-21T02:26:46.380Z]       /usr/local/go/src/testing/testing.go:1486 +0x47

[2022-07-21T02:26:46.380Z] 

[2022-07-21T02:26:46.380Z] Goroutine 104 (finished) created at:

[2022-07-21T02:26:46.380Z]   github.com/pingcap/tiflow/cmd/dm-worker.main()

[2022-07-21T02:26:46.380Z]       /home/jenkins/agent/workspace/dm_ghpr_integration_test/go/src/github.com/pingcap/tiflow/cmd/dm-worker/main.go:88 +0x938

[2022-07-21T02:26:46.380Z]   github.com/pingcap/tiflow/cmd/dm-worker.TestRunMain.func3()

[2022-07-21T02:26:46.380Z]       /home/jenkins/agent/workspace/dm_ghpr_integration_test/go/src/github.com/pingcap/tiflow/cmd/dm-worker/main_test.go:66 +0x2b

[2022-07-21T02:26:46.380Z] ==================

What did you expect to see?

No response

What did you see instead?

No response

Versions of the cluster

master

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

(paste current status of DM cluster here)

[D3Hunter]

/assign @liumengya94

[ti-chi-bot]

@D3Hunter: GitHub didn't allow me to assign the following users: liumengya94.

Note that only pingcap members, repo collaborators and people who have commented on this issue/PR can be assigned. Additionally, issues/PRs can only have 10 assignees at the same time. For more information please see the contributor guide

In response to this:

/assign @liumengya94

Instructions for interacting with me using PR comments are available here. If you have questions or suggestions related to my behavior, please file an issue against the kubernetes/test-infra repository.

[niubell]

/assign liumengya94

[niubell]

/assign @liumengya94

[ti-chi-bot]

@niubell: GitHub didn't allow me to assign the following users: liumengya94.

Note that only pingcap members, repo collaborators and people who have commented on this issue/PR can be assigned. Additionally, issues/PRs can only have 10 assignees at the same time. For more information please see the contributor guide

In response to this:

/assign @liumengya94

Instructions for interacting with me using PR comments are available here. If you have questions or suggestions related to my behavior, please file an issue against the kubernetes/test-infra repository.