pschnayder: Updating the StreamWriterClosedException to include clien…

…t side mitigation suggestions from the public documentation (#2784) * pschnayder: Updating the StreamWriterClosedException to include client side mitigation suggestions from the public documentation * Adding a period before the updated error message
googleapis · Dec 3, 2024 · 7703ab2 · 7703ab2
1 parent e4ec6f4
commit 7703ab2
Showing 1 changed file with 12 additions and 2 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
@@ -585,11 +585,21 @@ private ApiFuture<AppendRowsResponse> appendInternal(
       }
 
       if (connectionFinalStatus != null) {
+        String connectionFinalStatusString;
+        if (connectionFinalStatus
+            .toString()
+            .contains("com.google.api.gax.rpc.UnavailableException")) {
+          connectionFinalStatusString =
+              connectionFinalStatus.toString()
+                  + ". This is a most likely a transient condition and may be corrected by retrying"
+                  + " with a backoff.";
+        } else {
+          connectionFinalStatusString = connectionFinalStatus.toString();
+        }
         requestWrapper.appendResult.setException(
             new Exceptions.StreamWriterClosedException(
                 Status.fromCode(Status.Code.FAILED_PRECONDITION)
-                    .withDescription(
-                        "Connection is closed due to " + connectionFinalStatus.toString()),
+                    .withDescription("Connection is closed due to " + connectionFinalStatusString),
                 streamName,
                 writerId));
         return requestWrapper.appendResult;