aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorkomels <komels@ydb.tech>2022-09-16 17:38:16 +0300
committerkomels <komels@ydb.tech>2022-09-16 17:38:16 +0300
commit1f8614d61e3c3105e37ca88d36d15b675d3e010e (patch)
treeb3683b4e095392018e61e695a52cf4583bae474a
parent863f8001a8c5bdf25eb95edd587063f5deb93f8f (diff)
downloadydb-1f8614d61e3c3105e37ca88d36d15b675d3e010e.tar.gz
Bugfix
-rw-r--r--ydb/core/client/server/msgbus_server_persqueue.cpp2
1 files changed, 1 insertions, 1 deletions
diff --git a/ydb/core/client/server/msgbus_server_persqueue.cpp b/ydb/core/client/server/msgbus_server_persqueue.cpp
index 2dca4689cce..7089d6dabe2 100644
--- a/ydb/core/client/server/msgbus_server_persqueue.cpp
+++ b/ydb/core/client/server/msgbus_server_persqueue.cpp
@@ -423,7 +423,7 @@ TPersQueueBaseRequestProcessor::TNodesInfo::TNodesInfo(THolder<TEvInterconnect::
for (const NActors::TEvInterconnect::TNodeInfo& info : NodesInfoReply->Nodes) {
HostNames.emplace(info.NodeId, info.Host);
auto insRes = MinNodeIdByHost.insert(std::make_pair(info.Host, info.NodeId));
- if (insRes.second) {
+ if (!insRes.second) {
if (insRes.first->second > info.NodeId) {
insRes.first->second = info.NodeId;
}