From a46d327cfd689d6748c241725f38c861e571a5a6 Mon Sep 17 00:00:00 2001 From: Evan Greco Date: Wed, 8 Nov 2023 19:33:59 +0000 Subject: [PATCH] Add more debugging logs for connection worker test --- .../com/google/cloud/bigquery/storage/v1/StreamWriter.java | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/StreamWriter.java b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/StreamWriter.java index 538bec4e32..c6e40ba41b 100644 --- a/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/StreamWriter.java +++ b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/StreamWriter.java @@ -375,6 +375,11 @@ private void validateFetchedConnectonPool(StreamWriter.Builder builder) { if (!Objects.equals( this.singleConnectionOrConnectionPool.connectionWorkerPool().getTraceId(), builder.traceId)) { + log.info( + String.format( + "first: %s, second: %s", + this.singleConnectionOrConnectionPool.connectionWorkerPool().getTraceId(), + builder.traceId)); paramsValidatedFailed = "Trace id"; } else if (!Objects.equals( this.singleConnectionOrConnectionPool.connectionWorkerPool().limitExceededBehavior(),