Improve error message in GcsUtil (#23482)

apache · Oct 5, 2022 · b7b7136 · b7b7136
1 parent 0bbfb4a
commit b7b7136
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/...le-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/GcsUtil.java b/...le-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/GcsUtil.java
@@ -930,7 +930,9 @@ public void onFailure(GoogleJsonError e, HttpHeaders responseHeaders) throws IOE
           readyToEnqueue = false;
           lastError = null;
         } else {
-          throw new FileNotFoundException(e.getMessage());
+          throw new FileNotFoundException(
+              String.format(
+                  "Source %s not found. Failed with error: %s", from.toString(), e.getMessage()));
         }
       } else if (e.getCode() == 403
           && e.getErrors().size() == 1