diff --git a/java-bigquerystorage/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/ConnectionWorker.java b/java-bigquerystorage/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/ConnectionWorker.java index 6e353617e36d..f425ee235933 100644 --- a/java-bigquerystorage/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/ConnectionWorker.java +++ b/java-bigquerystorage/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/ConnectionWorker.java @@ -878,7 +878,6 @@ private void appendLoop() { // Consider the backend latency as completed for the current request. requestProfilerHook.endOperation( RequestProfiler.OperationName.RESPONSE_LATENCY, requestWrapper.requestUniqueId); - requestWrapper.requestSendTimeStamp = null; requestProfilerHook.startOperation( RequestProfiler.OperationName.WAIT_QUEUE, requestWrapper.requestUniqueId); waitingRequestQueue.addFirst(requestWrapper); @@ -1454,7 +1453,6 @@ private void doneCallback(Throwable finalStatus) { private AppendRequestAndResponse pollInflightRequestQueue(boolean pollLast) { AppendRequestAndResponse requestWrapper = pollLast ? inflightRequestQueue.pollLast() : inflightRequestQueue.poll(); - requestWrapper.requestSendTimeStamp = null; --this.inflightRequests; this.inflightBytes -= requestWrapper.messageSize; this.inflightReduced.signal(); @@ -1501,7 +1499,7 @@ static final class AppendRequestAndResponse { long recordBatchRowCount = -1; // Time at which request was last sent over the network. - // If a response is no longer expected this is set back to null. + // This is set ONLY by the appendLoop thread. Instant requestSendTimeStamp; AppendRequestAndResponse(