fix ut

pingcap · Sep 26, 2024 · 07b7a86 · 07b7a86
1 parent 9b0f471
commit 07b7a86
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/cdc/owner/ddl_sink_test.go b/cdc/owner/ddl_sink_test.go
@@ -82,7 +82,7 @@ func TestCheckpoint(t *testing.T) {
 	ctx, cancel := context.WithCancel(context.Background())
 	defer func() {
 		cancel()
-		ddlSink.close(ctx)
+		ddlSink.close()
 	}()
 	ddlSink.run(ctx)
 
@@ -106,7 +106,7 @@ func TestExecDDLEvents(t *testing.T) {
 	ctx, cancel := context.WithCancel(context.Background())
 	defer func() {
 		cancel()
-		ddlSink.close(ctx)
+		ddlSink.close()
 	}()
 	ddlSink.run(ctx)
 
@@ -150,7 +150,7 @@ func TestExecDDLError(t *testing.T) {
 	ctx, cancel := context.WithCancel(context.Background())
 	defer func() {
 		cancel()
-		ddlSink.close(ctx)
+		ddlSink.close()
 	}()
 
 	ddlSink.run(ctx)