diff --git a/hadoop-ozone/client/src/main/java/org/apache/hadoop/ozone/client/protocol/ClientProtocol.java b/hadoop-ozone/client/src/main/java/org/apache/hadoop/ozone/client/protocol/ClientProtocol.java index 8502fec3c52a..7da2108038c7 100644 --- a/hadoop-ozone/client/src/main/java/org/apache/hadoop/ozone/client/protocol/ClientProtocol.java +++ b/hadoop-ozone/client/src/main/java/org/apache/hadoop/ozone/client/protocol/ClientProtocol.java @@ -762,7 +762,7 @@ OzoneKey headObject(String volumeName, String bucketName, * of the S3 API implementation within Ozone. * @param s3Auth authentication information for each S3 API call. */ - void setTheadLocalS3Auth(S3Auth s3Auth); + void setThreadLocalS3Auth(S3Auth s3Auth); /** * Gets the S3 Authentication information that is attached to the thread. @@ -773,7 +773,7 @@ OzoneKey headObject(String volumeName, String bucketName, /** * Clears the S3 Authentication information attached to the thread. */ - void clearTheadLocalS3Auth(); + void clearThreadLocalS3Auth(); /** * Sets the owner of bucket. diff --git a/hadoop-ozone/client/src/main/java/org/apache/hadoop/ozone/client/rpc/RpcClient.java b/hadoop-ozone/client/src/main/java/org/apache/hadoop/ozone/client/rpc/RpcClient.java index 328044184b02..28efa8c91245 100644 --- a/hadoop-ozone/client/src/main/java/org/apache/hadoop/ozone/client/rpc/RpcClient.java +++ b/hadoop-ozone/client/src/main/java/org/apache/hadoop/ozone/client/rpc/RpcClient.java @@ -1632,7 +1632,7 @@ public OzoneKey headObject(String volumeName, String bucketName, } @Override - public void setTheadLocalS3Auth( + public void setThreadLocalS3Auth( S3Auth ozoneSharedSecretAuth) { ozoneManagerClient.setThreadLocalS3Auth(ozoneSharedSecretAuth); } @@ -1643,7 +1643,7 @@ public S3Auth getThreadLocalS3Auth() { } @Override - public void clearTheadLocalS3Auth() { + public void clearThreadLocalS3Auth() { ozoneManagerClient.clearThreadLocalS3Auth(); } diff --git a/hadoop-ozone/s3gateway/src/main/java/org/apache/hadoop/ozone/s3/OzoneClientProducer.java b/hadoop-ozone/s3gateway/src/main/java/org/apache/hadoop/ozone/s3/OzoneClientProducer.java index 0cd5b4a455c8..28c3958882e5 100644 --- a/hadoop-ozone/s3gateway/src/main/java/org/apache/hadoop/ozone/s3/OzoneClientProducer.java +++ b/hadoop-ozone/s3gateway/src/main/java/org/apache/hadoop/ozone/s3/OzoneClientProducer.java @@ -77,7 +77,7 @@ public synchronized OzoneClient createClient() throws WebApplicationException, @PreDestroy public void destroy() throws IOException { - client.getObjectStore().getClientProxy().clearTheadLocalS3Auth(); + client.getObjectStore().getClientProxy().clearThreadLocalS3Auth(); } @Produces public S3Auth getSignature() { diff --git a/hadoop-ozone/s3gateway/src/main/java/org/apache/hadoop/ozone/s3/endpoint/EndpointBase.java b/hadoop-ozone/s3gateway/src/main/java/org/apache/hadoop/ozone/s3/endpoint/EndpointBase.java index ffd95cb6be18..b93336374ead 100644 --- a/hadoop-ozone/s3gateway/src/main/java/org/apache/hadoop/ozone/s3/endpoint/EndpointBase.java +++ b/hadoop-ozone/s3gateway/src/main/java/org/apache/hadoop/ozone/s3/endpoint/EndpointBase.java @@ -74,9 +74,9 @@ protected OzoneBucket getBucket(OzoneVolume volume, String bucketName) @PostConstruct public void initialization() { LOG.debug("S3 access id: {}", s3Auth.getAccessID()); - getClient().getObjectStore(). - getClientProxy(). - setTheadLocalS3Auth(s3Auth); + getClient().getObjectStore() + .getClientProxy() + .setThreadLocalS3Auth(s3Auth); init(); }