fix: extra logging for investigation of the stuck case.

README.md

@@ -49,20 +49,20 @@ If you are using Maven without 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.7.0')
+implementation platform('com.google.cloud:libraries-bom:26.8.0')
 
 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.31.0'
+implementation 'com.google.cloud:google-cloud-bigquerystorage:2.31.1'
 ```
 
 If you are using SBT, add this to your dependencies:
 
 ```Scala
-libraryDependencies += "com.google.cloud" % "google-cloud-bigquerystorage" % "2.31.0"
+libraryDependencies += "com.google.cloud" % "google-cloud-bigquerystorage" % "2.31.1"
 ```
 
 ## Authentication

google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/ConnectionWorker.java

@@ -581,7 +581,17 @@ private void appendLoop() {
  }
  }
 
- log.fine("Cleanup starts. Stream: " + streamName + " id: " + writerId);
+ log.info(
+ "Cleanup starts. Stream: "
+ + streamName
+ + " id: "
+ + writerId
+ + " userClose: "
+ + userClosed
+ + " final exception: "
+ + (this.connectionFinalStatus == null
+ ? "null"
+ : this.connectionFinalStatus.toString()));
  // At this point, the waiting queue is drained, so no more requests.
  // We can close the stream connection and handle the remaining inflight requests.
  if (streamConnection != null) {
@@ -590,13 +600,13 @@ private void appendLoop() {
  }
 
  // At this point, there cannot be more callback. It is safe to clean up all inflight requests.
- log.fine(
+ log.info(
  "Stream connection is fully closed. Cleaning up inflight requests. Stream: "
  + streamName
  + " id: "
  + writerId);
  cleanupInflightRequests();
- log.fine("Append thread is done. Stream: " + streamName + " id: " + writerId);
+ log.info("Append thread is done. Stream: " + streamName + " id: " + writerId);
  }
 
  /*
@@ -809,7 +819,9 @@ private void doneCallback(Throwable finalStatus) {
  + (maxRetryDuration.toMillis()
  - (System.currentTimeMillis() - connectionRetryStartTime))
  + ", for stream "
- + streamName);
+ + streamName
+ + " id:"
+ + writerId);
  } else {
  Exceptions.StorageException storageException = Exceptions.toStorageException(finalStatus);
  this.connectionFinalStatus = storageException != null ? storageException : finalStatus;