Skip to content

Commit 734d4bb

Browse files
committed
Revert "[APPEND][FSTORE-1536] Add S3 endpoint (#356)"
This reverts commit 36ee228.
1 parent ad16302 commit 734d4bb

File tree

1 file changed

+1
-4
lines changed

1 file changed

+1
-4
lines changed

python/hsfs/storage_connector.py

+1-4
Original file line numberDiff line numberDiff line change
@@ -374,15 +374,12 @@ def prepare_spark(self, path: Optional[str] = None) -> Optional[str]:
374374
def connector_options(self) -> Dict[str, Any]:
375375
"""Return options to be passed to an external S3 connector library"""
376376
self.refetch()
377-
options = {
377+
return {
378378
"access_key": self.access_key,
379379
"secret_key": self.secret_key,
380380
"session_token": self.session_token,
381381
"region": self.region,
382382
}
383-
if self.arguments.get("fs.s3a.endpoint"):
384-
options["endpoint"] = self.arguments.get("fs.s3a.endpoint")
385-
return options
386383

387384
def read(
388385
self,

0 commit comments

Comments
 (0)