feat: add two fine logs that would allow Datastream to look into the …

…stuck issue (#1791)
googleapis · Sep 22, 2022 · 745ceb4 · 745ceb4
1 parent 18f93c1
commit 745ceb4
Showing 1 changed file with 13 additions and 0 deletions.
diff --git a/...-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/ConnectionWorker.java b/...-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/ConnectionWorker.java
@@ -488,6 +488,12 @@ private void appendLoop() {
         // TODO: Handle NOT_ENOUGH_QUOTA.
         // In the close case, the request is in the inflight queue, and will either be returned
         // to the user with an error, or will be resent.
+        log.fine(
+            "Sending "
+                + originalRequestBuilder.getProtoRows().getRows().getSerializedRowsCount()
+                + " rows to stream '"
+                + originalRequestBuilder.getWriteStream()
+                + "'");
         this.streamConnection.send(originalRequestBuilder.build());
       }
     }
@@ -580,6 +586,13 @@ private void cleanupInflightRequests() {
   }
 
   private void requestCallback(AppendRowsResponse response) {
+    log.fine(
+        "Got response on stream '"
+            + response.getWriteStream()
+            + "' "
+            + (response.hasError()
+                ? "error: " + response.getError()
+                : "offset: " + response.getAppendResult().getOffset().getValue()));
     AppendRequestAndResponse requestWrapper;
     this.lock.lock();
     if (response.hasUpdatedSchema()) {