fix: Set nodeID when remove distribution (#31259)

See also #30930

Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
This commit is contained in:
congqixia 2024-03-14 15:09:03 +08:00 committed by GitHub
parent 6939ad15f2
commit 773c64ecbb
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194

View File

@ -526,6 +526,7 @@ func (ex *Executor) removeDistribution(task *LeaderTask, step int) error {
{ {
Type: querypb.SyncType_Remove, Type: querypb.SyncType_Remove,
SegmentID: action.SegmentID(), SegmentID: action.SegmentID(),
NodeID: action.Node(),
}, },
}, },
} }