From 88da0251af4a279e37dad256e98627a65b76e2ea Mon Sep 17 00:00:00 2001 From: "cai.zhang" Date: Tue, 23 Jul 2024 10:25:52 +0800 Subject: [PATCH] fix: [cherry-pick] Get current index version from knowhere (#34902) issue: #34900 master pr: #34901 Signed-off-by: Cai Zhang --- internal/indexnode/task_index.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/internal/indexnode/task_index.go b/internal/indexnode/task_index.go index c650e0cbf4..bc3843cc4a 100644 --- a/internal/indexnode/task_index.go +++ b/internal/indexnode/task_index.go @@ -376,6 +376,8 @@ func (it *indexBuildTask) PreExecute(ctx context.Context) error { } } + it.req.CurrentIndexVersion = getCurrentIndexVersion(it.req.GetCurrentIndexVersion()) + log.Ctx(ctx).Info("Successfully prepare indexBuildTask", zap.Int64("buildID", it.req.GetBuildID()), zap.Int64("collectionID", it.req.GetCollectionID()), zap.Int64("segmentID", it.req.GetSegmentID())) return nil @@ -566,7 +568,6 @@ func (it *indexBuildTask) parseFieldMetaFromBinlog(ctx context.Context) error { break } } - it.req.CurrentIndexVersion = getCurrentIndexVersion(it.req.GetCurrentIndexVersion()) return nil }