diff --git a/java-bigtable/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/internal/channels/FallbackChannelPool.java b/java-bigtable/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/internal/channels/FallbackChannelPool.java index 1558da2af18d..ea8cd22d1292 100644 --- a/java-bigtable/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/internal/channels/FallbackChannelPool.java +++ b/java-bigtable/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/internal/channels/FallbackChannelPool.java @@ -135,7 +135,7 @@ public SessionStream newStream( final SessionStream stream = current.newStream(desc, callOptions); return new ForwardingSessionStream(stream) { - private boolean ignoreError; + private volatile boolean ignoreError; @Override public void start(Listener responseListener, Metadata headers) {