Skip to content

Commit 9c61660

Browse files
committed
fix tests
1 parent a157c2f commit 9c61660

2 files changed

Lines changed: 1 addition & 5 deletions

File tree

java-spanner/google-cloud-spanner/src/main/java/com/google/cloud/spanner/AbstractReadContext.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -205,8 +205,7 @@ private SingleReadContext(Builder builder) {
205205
// with a multiplexed session to perform a round-robin channel selection. We are
206206
// passing a hint here to prefer random channel selection instead of doing GAX round-robin.
207207
// Also signal unbind so the grpc-gcp affinity map entry is cleaned up once the call
208-
// completes. The retry path (prepareRetryOnDifferentGrpcChannel) does NOT carry this
209-
// flag, so resumed streams will re-bind to a fresh key without early unbind.
208+
// completes. The unbind flag is preserved on retries via prepareRetryOnDifferentGrpcChannel.
210209
this.channelHint =
211210
getChannelHintOptions(
212211
session.getOptions(),

java-spanner/google-cloud-spanner/src/main/java/com/google/cloud/spanner/spi/v1/KeyRangeCache.java

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -639,9 +639,6 @@ && leader().distance <= MAX_LOCAL_REPLICA_DISTANCE) {
639639
}
640640
}
641641
for (int index = 0; index < tablets.size(); index++) {
642-
if (checkedLeader && index == leaderIndex) {
643-
continue;
644-
}
645642
CachedTablet tablet = tablets.get(index);
646643
if (!tablet.matches(directedReadOptions)) {
647644
continue;

0 commit comments

Comments
 (0)