You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ozone.apache.org by jy...@apache.org on 2022/06/03 06:27:29 UTC
[ozone] branch master updated: HDDS-6811. Bucket create message with layout type (#3479)
This is an automated email from the ASF dual-hosted git repository.
jyotinder pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ozone.git
The following commit(s) were added to refs/heads/master by this push:
new a5858ddadb HDDS-6811. Bucket create message with layout type (#3479)
a5858ddadb is described below
commit a5858ddadb66d670b24ade6084d1d112dae2eb5e
Author: tanvipenumudy <46...@users.noreply.github.com>
AuthorDate: Fri Jun 3 11:57:23 2022 +0530
HDDS-6811. Bucket create message with layout type (#3479)
---
.../java/org/apache/hadoop/ozone/client/rpc/RpcClient.java | 11 +++++++----
1 file changed, 7 insertions(+), 4 deletions(-)
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 1c59ab1e4b..016eff52d3 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
@@ -101,6 +101,7 @@ import org.apache.hadoop.ozone.client.io.OzoneOutputStream;
import org.apache.hadoop.ozone.client.protocol.ClientProtocol;
import org.apache.hadoop.ozone.om.OMConfigKeys;
import org.apache.hadoop.ozone.om.exceptions.OMException;
+import org.apache.hadoop.ozone.om.helpers.BucketLayout;
import org.apache.hadoop.ozone.om.helpers.BucketEncryptionKeyInfo;
import org.apache.hadoop.ozone.om.helpers.DeleteTenantState;
import org.apache.hadoop.ozone.om.helpers.OmBucketArgs;
@@ -625,6 +626,7 @@ public class RpcClient implements ClientProtocol {
Boolean.FALSE : bucketArgs.getVersioning();
StorageType storageType = bucketArgs.getStorageType() == null ?
StorageType.DEFAULT : bucketArgs.getStorageType();
+ BucketLayout bucketLayout = bucketArgs.getBucketLayout();
BucketEncryptionKeyInfo bek = null;
if (bucketArgs.getEncryptionKey() != null) {
bek = new BucketEncryptionKeyInfo.Builder()
@@ -648,7 +650,7 @@ public class RpcClient implements ClientProtocol {
.setQuotaInBytes(bucketArgs.getQuotaInBytes())
.setQuotaInNamespace(bucketArgs.getQuotaInNamespace())
.setAcls(listOfAcls.stream().distinct().collect(Collectors.toList()))
- .setBucketLayout(bucketArgs.getBucketLayout())
+ .setBucketLayout(bucketLayout)
.setOwner(owner);
if (bek != null) {
@@ -661,9 +663,10 @@ public class RpcClient implements ClientProtocol {
builder.setDefaultReplicationConfig(defaultReplicationConfig);
}
- LOG.info("Creating Bucket: {}/{}, with {} as owner and Versioning {} and " +
- "Storage Type set to {} and Encryption set to {} ",
- volumeName, bucketName, owner, isVersionEnabled,
+ LOG.info("Creating Bucket: {}/{}, with the Bucket Layout {}, {} as " +
+ "owner, Versioning {}, Storage Type set to {} and Encryption set " +
+ "to {} ",
+ volumeName, bucketName, bucketLayout, owner, isVersionEnabled,
storageType, bek != null);
ozoneManagerClient.createBucket(builder.build());
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@ozone.apache.org
For additional commands, e-mail: commits-help@ozone.apache.org