diff --git a/ddl/syncer/state_syncer_test.go b/ddl/syncer/state_syncer_test.go
index 584de2889e..107e0d0e36 100644
--- a/ddl/syncer/state_syncer_test.go
+++ b/ddl/syncer/state_syncer_test.go
@@ -62,9 +62,10 @@ func TestStateSyncerSimple(t *testing.T) {
 		WithLease(testLease),
 		WithInfoCache(ic),
 	)
-	go func() {
+	var wg util.WaitGroupWrapper
+	wg.Run(func() {
 		require.NoError(t, d.OwnerManager().CampaignOwner())
-	}()
+	})
 	defer d.OwnerManager().Cancel()
 	// TODO: We can remove it when we call it in newDDL.
 	require.NoError(t, d.StateSyncer().Init(ctx))
@@ -77,7 +78,6 @@ func TestStateSyncerSimple(t *testing.T) {
 	require.Equal(t, stateInfo, respState)
 	require.False(t, d.StateSyncer().IsUpgradingState())
 	// for watchCh
-	var wg util.WaitGroupWrapper
 	var checkErr string
 	stateInfo.State = syncer.StateUpgrading
 	stateInfoByte, err := stateInfo.Marshal()