.

yirutang · yirutang · commit e071feef9b10 · 2023-02-14T22:35:49.000Z
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
@@ -581,7 +581,7 @@ private void appendLoop() {
       }
     }
 
-    log.fine("Cleanup starts. Stream: " + streamName + " id: " + writerId);
+    log.info("Cleanup starts. Stream: " + streamName + " id: " + writerId);
     // 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 +590,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 +809,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;
