diff --git a/README.md b/README.md index b3cd39b583..2265cbbf99 100644 --- a/README.md +++ b/README.md @@ -56,13 +56,13 @@ implementation 'com.google.cloud:google-cloud-bigquerystorage' If you are using Gradle without BOM, add this to your dependencies ```Groovy -implementation 'com.google.cloud:google-cloud-bigquerystorage:2.3.3' +implementation 'com.google.cloud:google-cloud-bigquerystorage:2.4.0' ``` If you are using SBT, add this to your dependencies ```Scala -libraryDependencies += "com.google.cloud" % "google-cloud-bigquerystorage" % "2.3.3" +libraryDependencies += "com.google.cloud" % "google-cloud-bigquerystorage" % "2.4.0" ``` ## Authentication 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 80a935ee93..3f94a85f03 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 @@ -307,7 +307,7 @@ public void close() { } finally { this.lock.unlock(); } - log.info("Waiting for append thread to finish. Stream: " + streamName); + log.fine("Waiting for append thread to finish. Stream: " + streamName); try { appendThread.join(); log.info("User close complete. Stream: " + streamName); @@ -366,17 +366,17 @@ private void appendLoop() { } } - log.info("Cleanup starts. Stream: " + streamName); + log.fine("Cleanup starts. Stream: " + streamName); // At this point, the waiting queue is drained, so no more requests. // We can close the stream connection and handle the remaining inflight requests. this.streamConnection.close(); waitForDoneCallback(); // At this point, there cannot be more callback. It is safe to clean up all inflight requests. - log.info( + log.fine( "Stream connection is fully closed. Cleaning up inflight requests. Stream: " + streamName); cleanupInflightRequests(); - log.info("Append thread is done. Stream: " + streamName); + log.fine("Append thread is done. Stream: " + streamName); } /* @@ -396,7 +396,7 @@ private boolean waitingQueueDrained() { } private void waitForDoneCallback() { - log.info("Waiting for done callback from stream connection. Stream: " + streamName); + log.fine("Waiting for done callback from stream connection. Stream: " + streamName); while (true) { this.lock.lock(); try { @@ -441,7 +441,7 @@ private void cleanupInflightRequests() { } finally { this.lock.unlock(); } - log.info( + log.fine( "Cleaning " + localQueue.size() + " inflight requests with error: " @@ -471,7 +471,7 @@ private void requestCallback(AppendRowsResponse response) { } private void doneCallback(Throwable finalStatus) { - log.info( + log.fine( "Received done callback. Stream: " + streamName + " Final status: " diff --git a/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/StreamWriterV2.java b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/StreamWriterV2.java index 1d83af111e..43496f667b 100644 --- a/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/StreamWriterV2.java +++ b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/StreamWriterV2.java @@ -307,7 +307,7 @@ public void close() { } finally { this.lock.unlock(); } - log.info("Waiting for append thread to finish. Stream: " + streamName); + log.fine("Waiting for append thread to finish. Stream: " + streamName); try { appendThread.join(); log.info("User close complete. Stream: " + streamName); @@ -366,17 +366,17 @@ private void appendLoop() { } } - log.info("Cleanup starts. Stream: " + streamName); + log.fine("Cleanup starts. Stream: " + streamName); // At this point, the waiting queue is drained, so no more requests. // We can close the stream connection and handle the remaining inflight requests. this.streamConnection.close(); waitForDoneCallback(); // At this point, there cannot be more callback. It is safe to clean up all inflight requests. - log.info( + log.fine( "Stream connection is fully closed. Cleaning up inflight requests. Stream: " + streamName); cleanupInflightRequests(); - log.info("Append thread is done. Stream: " + streamName); + log.fine("Append thread is done. Stream: " + streamName); } /* @@ -396,7 +396,7 @@ private boolean waitingQueueDrained() { } private void waitForDoneCallback() { - log.info("Waiting for done callback from stream connection. Stream: " + streamName); + log.fine("Waiting for done callback from stream connection. Stream: " + streamName); while (true) { this.lock.lock(); try { @@ -441,7 +441,7 @@ private void cleanupInflightRequests() { } finally { this.lock.unlock(); } - log.info( + log.fine( "Cleaning " + localQueue.size() + " inflight requests with error: " @@ -471,7 +471,7 @@ private void requestCallback(AppendRowsResponse response) { } private void doneCallback(Throwable finalStatus) { - log.info( + log.fine( "Received done callback. Stream: " + streamName + " Final status: "