From 6fd33285e104a4aa514df64f5321b5fe9a1aedfa Mon Sep 17 00:00:00 2001 From: "yihao.dai" Date: Mon, 2 Sep 2024 14:50:35 +0800 Subject: [PATCH] fix: Fix compile error (#35901) /kind improvement Signed-off-by: bigsheeper --- internal/datanode/compaction/merge_sort.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/datanode/compaction/merge_sort.go b/internal/datanode/compaction/merge_sort.go index 351a27043c..f9294b3620 100644 --- a/internal/datanode/compaction/merge_sort.go +++ b/internal/datanode/compaction/merge_sort.go @@ -36,7 +36,7 @@ func mergeSortMultipleSegments(ctx context.Context, log := log.With(zap.Int64("planID", plan.GetPlanID())) - segIDAlloc := allocator.NewLocalAllocator(plan.GetPreAllocatedSegments().GetBegin(), plan.GetPreAllocatedSegments().GetEnd()) + segIDAlloc := allocator.NewLocalAllocator(plan.GetPreAllocatedSegmentIDs().GetBegin(), plan.GetPreAllocatedSegmentIDs().GetEnd()) logIDAlloc := allocator.NewLocalAllocator(plan.GetBeginLogID(), math.MaxInt64) compAlloc := NewCompactionAllocator(segIDAlloc, logIDAlloc) mWriter := NewMultiSegmentWriter(binlogIO, compAlloc, plan, maxRows, partitionID, collectionID)