diff --git a/cdc/owner/ddl_sink_test.go b/cdc/owner/ddl_sink_test.go
index 4cf6780204a..52ef2abe092 100644
--- 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)