modify registry.db s3 object initialization to work in S3 subdirectory with Java Feast Server (feast-dev#2259)

NalinGHub · web-flow · commit 2e4f3e55e6f7 · 2022-01-30T14:52:52.000-08:00
Signed-off-by: NalinGHub &lt;nalinm01@gmail.com&gt;
diff --git a/java/serving/src/main/java/feast/serving/registry/S3RegistryFile.java b/java/serving/src/main/java/feast/serving/registry/S3RegistryFile.java
@@ -33,7 +33,8 @@ public S3RegistryFile(AmazonS3 s3Client, String url) {
     this.s3Client = s3Client;
 
     String[] split = url.replace("s3://", "").split("/");
-    this.s3Object = this.s3Client.getObject(split[0], split[1]);
+    String objectPath = String.join("/", java.util.Arrays.copyOfRange(split, 1, split.length));
+    this.s3Object = this.s3Client.getObject(split[0], objectPath);
   }
 
   @Override

Original file line number	Diff line number	Diff line change
`@@ -33,7 +33,8 @@ public S3RegistryFile(AmazonS3 s3Client, String url) {`
`33`	`33`	`this.s3Client = s3Client;`
`34`	`34`
`35`	`35`	`String[] split = url.replace("s3://", "").split("/");`
`36`		`- this.s3Object = this.s3Client.getObject(split[0], split[1]);`
	`36`	`+ String objectPath = String.join("/", java.util.Arrays.copyOfRange(split, 1, split.length));`
	`37`	`+ this.s3Object = this.s3Client.getObject(split[0], objectPath);`
`37`	`38`	`}`
`38`	`39`
`39`	`40`	`@Override`