diff options
author | komels <komels@ydb.tech> | 2022-09-16 17:38:16 +0300 |
---|---|---|
committer | komels <komels@ydb.tech> | 2022-09-16 17:38:16 +0300 |
commit | 1f8614d61e3c3105e37ca88d36d15b675d3e010e (patch) | |
tree | b3683b4e095392018e61e695a52cf4583bae474a | |
parent | 863f8001a8c5bdf25eb95edd587063f5deb93f8f (diff) | |
download | ydb-1f8614d61e3c3105e37ca88d36d15b675d3e010e.tar.gz |
Bugfix
-rw-r--r-- | ydb/core/client/server/msgbus_server_persqueue.cpp | 2 |
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; } |