From 07b7a86fd8a8a88676d1f3c999d4853ee7dc2eb3 Mon Sep 17 00:00:00 2001 From: 3AceShowHand Date: Thu, 26 Sep 2024 13:20:34 +0800 Subject: [PATCH] fix ut --- cdc/owner/ddl_sink_test.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) 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)