diff --git a/sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/GcsUtil.java b/sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/GcsUtil.java index 2acec4f23861..d6e3ba3c921f 100644 --- a/sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/GcsUtil.java +++ b/sdks/java/extensions/google-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