diff --git a/java-bigtable/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/internal/session/SessionImpl.java b/java-bigtable/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/internal/session/SessionImpl.java index a2ef4f619821..9ee86bffbdbd 100644 --- a/java-bigtable/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/internal/session/SessionImpl.java +++ b/java-bigtable/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/internal/session/SessionImpl.java @@ -113,7 +113,7 @@ public class SessionImpl implements Session, VRpcSessionApi { private VRpcResult currentCancel = null; private SessionParametersResponse sessionParameters = DEFAULT_SESSION_PARAMS; - private Duration heartbeatInterval = + private volatile Duration heartbeatInterval = Duration.ofMillis(Durations.toMillis(sessionParameters.getKeepAlive())); private volatile Instant nextHeartbeat;