aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorkomels <komels@ydb.tech>2022-09-15 19:03:50 +0300
committerkomels <komels@ydb.tech>2022-09-15 19:03:50 +0300
commite13e0cbfa495fea6d77c2293d096b440feef81dd (patch)
tree5c0791f408e925248e345d145efca041cbfb93ed
parent3895bf6da495927577224d3cb636e536f78478fa (diff)
downloadydb-e13e0cbfa495fea6d77c2293d096b440feef81dd.tar.gz
Fix the bug
-rw-r--r--ydb/core/client/server/msgbus_server_pq_metarequest.cpp8
1 files changed, 4 insertions, 4 deletions
diff --git a/ydb/core/client/server/msgbus_server_pq_metarequest.cpp b/ydb/core/client/server/msgbus_server_pq_metarequest.cpp
index 479e30497f3..11152f41de3 100644
--- a/ydb/core/client/server/msgbus_server_pq_metarequest.cpp
+++ b/ydb/core/client/server/msgbus_server_pq_metarequest.cpp
@@ -418,11 +418,11 @@ void TPersQueueGetPartitionLocationsTopicWorker::Answer(
location.SetHost(hostName->second);
location.SetErrorCode(NPersQueue::NErrorCode::OK);
auto dynamicIter = NodesInfo->DynamicNodeIdsOverride.find(nodeId);
- if (!dynamicIter.IsEnd()) {
- Y_VERIFY(dynamicIter->first < dynamicIter->second);
- location.SetHostId(dynamicIter->second);
- } else {
+ if (dynamicIter.IsEnd()) {
location.SetHostId(nodeId);
+ } else {
+ Y_VERIFY(dynamicIter->first > dynamicIter->second);
+ location.SetHostId(dynamicIter->second);
}
} else {
statusInitializing = true;