Fix x-goog-request-params bucket prefix (#1015) (#1016)

GoogleCloudDataproc · Jun 23, 2023 · fbd5eb8 · fbd5eb8
1 parent f132b96
commit fbd5eb8
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/gcsio/src/main/java/com/google/cloud/hadoop/gcsio/StorageStubProvider.java b/gcsio/src/main/java/com/google/cloud/hadoop/gcsio/StorageStubProvider.java
@@ -92,7 +92,7 @@ protected StorageStub newAsyncStubInternal() {
 
   private static Metadata getRequestHeaderMetadata(String bucketName) {
     Metadata metadata = new Metadata();
-    metadata.put(GOOG_REQUEST_PARAMS, String.format("bucket=%s", bucketName));
+    metadata.put(GOOG_REQUEST_PARAMS, String.format("bucket=projects/_/buckets/%s", bucketName));
     return metadata;
   }
 

diff --git a/gcsio/src/test/java/com/google/cloud/hadoop/gcsio/TestServerHeaderInterceptor.java b/gcsio/src/test/java/com/google/cloud/hadoop/gcsio/TestServerHeaderInterceptor.java
@@ -27,7 +27,7 @@ void verifyAllRequestsHasGoogRequestParamsHeader(String bucket, int expectedCall
     assertEquals(expectedCallCount, allMeta.size());
     for (Metadata metadata : allMeta) {
       assertEquals(
-          String.format("bucket=%s", bucket),
+          String.format("bucket=projects/_/buckets/%s", bucket),
           metadata.get(StorageStubProvider.GOOG_REQUEST_PARAMS));
     }
   }