fix data race

pingcap · Nov 26, 2023 · 7cdfae2 · 7cdfae2
1 parent ee89b15
commit 7cdfae2
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/cdc/sink/ddlsink/cloudstorage/cloud_storage_ddl_sink_test.go b/cdc/sink/ddlsink/cloudstorage/cloud_storage_ddl_sink_test.go
@@ -19,6 +19,7 @@ import (
 	"net/url"
 	"os"
 	"path"
+	"sync/atomic"
 	"testing"
 	"time"
 
@@ -158,16 +159,16 @@ func TestCleanupExpiredFiles(t *testing.T) {
 	err = replicaConfig.ValidateAndAdjust(sinkURI)
 	require.Nil(t, err)
 
-	cnt := 0
+	cnt := atomic.Int64{}
 	cleanupJobs := []func(){
 		func() {
-			cnt++
+			cnt.Add(1)
 		},
 	}
 	sink, err := newDDLSink(ctx, model.DefaultChangeFeedID("test"), sinkURI, replicaConfig, cleanupJobs)
 	require.Nil(t, err)
 
 	_ = sink
 	time.Sleep(3 * time.Second)
-	require.LessOrEqual(t, 1, cnt)
+	require.LessOrEqual(t, int64(1), cnt.Load())
 }