diff --git a/src/client/partition_resolver_simple.cpp b/src/client/partition_resolver_simple.cpp index eb40f4e903..822f6096ed 100644 --- a/src/client/partition_resolver_simple.cpp +++ b/src/client/partition_resolver_simple.cpp @@ -415,14 +415,18 @@ void partition_resolver_simple::handle_pending_requests(std::deque last_drops; + GET_HOST_PORTS(pc, last_drops1, last_drops); + if (last_drops.empty()) { return host_port(); } - return pc.hp_last_drops1[rand::next_u32(0, pc.last_drops1.size() - 1)]; + return last_drops[rand::next_u32(0, last_drops.size() - 1)]; } error_code partition_resolver_simple::get_host_port(int partition_index, /*out*/ host_port &hp)