From ad1f3793dd8b270811f83bee905e137612570872 Mon Sep 17 00:00:00 2001 From: tangenta Date: Tue, 16 Apr 2024 16:32:43 +0800 Subject: [PATCH] fix ut TestBackfillOperators --- tests/realtikvtest/addindextest3/operator_test.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/tests/realtikvtest/addindextest3/operator_test.go b/tests/realtikvtest/addindextest3/operator_test.go index 067fdc672dd08..a1cf118e65227 100644 --- a/tests/realtikvtest/addindextest3/operator_test.go +++ b/tests/realtikvtest/addindextest3/operator_test.go @@ -135,13 +135,14 @@ func TestBackfillOperators(t *testing.T) { srcChkPool := make(chan *chunk.Chunk, regionCnt*2) pTbl := tbl.(table.PhysicalTable) index := tables.NewIndex(pTbl.GetPhysicalID(), tbl.Meta(), idxInfo) + mockBackendCtx := &ingest.MockBackendCtx{} mockEngine := ingest.NewMockEngineInfo(nil) mockEngine.SetHook(onWrite) src := newTestSource(chunkResults...) reorgMeta := ddl.NewDDLReorgMeta(tk.Session()) ingestOp := ddl.NewIndexIngestOperator( - opCtx, copCtx, sessPool, pTbl, []table.Index{index}, []ingest.Engine{mockEngine}, srcChkPool, 3, reorgMeta) + opCtx, copCtx, mockBackendCtx, sessPool, pTbl, []table.Index{index}, []ingest.Engine{mockEngine}, srcChkPool, 3, reorgMeta) sink := newTestSink[ddl.IndexWriteResult]() operator.Compose[ddl.IndexRecordChunk](src, ingestOp)