diff options
author | komels <komels@ydb.tech> | 2022-09-15 19:03:50 +0300 |
---|---|---|
committer | komels <komels@ydb.tech> | 2022-09-15 19:03:50 +0300 |
commit | e13e0cbfa495fea6d77c2293d096b440feef81dd (patch) | |
tree | 5c0791f408e925248e345d145efca041cbfb93ed | |
parent | 3895bf6da495927577224d3cb636e536f78478fa (diff) | |
download | ydb-e13e0cbfa495fea6d77c2293d096b440feef81dd.tar.gz |
Fix the bug
-rw-r--r-- | ydb/core/client/server/msgbus_server_pq_metarequest.cpp | 8 |
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; |