diff --git a/README.md b/README.md index e453f63b9a..d4392b52df 100644 --- a/README.md +++ b/README.md @@ -50,7 +50,7 @@ If you are using Maven without the BOM, add this to your dependencies: If you are using Gradle 5.x or later, add this to your dependencies: ```Groovy -implementation platform('com.google.cloud:libraries-bom:26.12.0') +implementation platform('com.google.cloud:libraries-bom:26.13.0') implementation 'com.google.cloud:google-cloud-bigquerystorage' ``` diff --git a/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/ConnectionWorker.java b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/ConnectionWorker.java index 12afbf13e0..64abf82bb9 100644 --- a/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/ConnectionWorker.java +++ b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/ConnectionWorker.java @@ -75,7 +75,7 @@ class ConnectionWorker implements AutoCloseable { * We will constantly checking how much time we have been waiting for the next request callback * if we wait too much time we will start shutting down the connections and clean up the queues. */ - static Duration MAXIMUM_REQUEST_CALLBACK_WAIT_TIME = Duration.ofMinutes(15); + static Duration MAXIMUM_REQUEST_CALLBACK_WAIT_TIME = Duration.ofMinutes(5); private Lock lock; private Condition hasMessageInWaitingQueue; @@ -321,7 +321,7 @@ public void run() { } private void resetConnection() { - log.info("Reconnecting for stream:" + streamName + " id: " + writerId); + log.info("Start connecting stream: " + streamName + " id: " + writerId); if (this.streamConnection != null) { // It's safe to directly close the previous connection as the in flight messages // will be picked up by the next connection. @@ -344,7 +344,7 @@ public void run(Throwable finalStatus) { doneCallback(finalStatus); } }); - log.info("Reconnect done for stream:" + streamName + " id: " + writerId); + log.info("Finish connecting stream: " + streamName + " id: " + writerId); } /** Schedules the writing of rows at given offset. */