diff --git a/src/Client/HedgedConnections.cpp b/src/Client/HedgedConnections.cpp index 8048d5cf1d4..558fe844447 100644 --- a/src/Client/HedgedConnections.cpp +++ b/src/Client/HedgedConnections.cpp @@ -296,7 +296,7 @@ HedgedConnections::ReplicaLocation HedgedConnections::getReadyReplicaLocation(As { ReplicaLocation location = replica_with_last_received_packet.value(); replica_with_last_received_packet.reset(); - if (resumePacketReceiver(location)) + if (offset_states[location.offset].replicas[location.index].connection->hasReadPendingData() && resumePacketReceiver(location)) return location; }