This is an automated email from the ASF dual-hosted git repository.
umamahesh pushed a commit to branch HDDS-3816-ec
in repository https://gitbox.apache.org/repos/asf/ozone.git
The following commit(s) were added to refs/heads/HDDS-3816-ec by this push:
new 4d660c4 HDDS-6233. EC: Bucket does not display correct EC replication
details (#3025)
4d660c4 is described below
commit 4d660c4d794964e65ce280ead2357ff681bdf640
Author: Stephen O'Donnell <[email protected]>
AuthorDate: Sat Jan 29 03:25:37 2022 +0000
HDDS-6233. EC: Bucket does not display correct EC replication details
(#3025)
---
.../apache/hadoop/ozone/client/rpc/RpcClient.java | 3 ++-
.../ozone/client/rpc/TestOzoneRpcClient.java | 28 ++++++++++++++++++++++
2 files changed, 30 insertions(+), 1 deletion(-)
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 d043939..5c20ef1 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
@@ -842,7 +842,8 @@ public class RpcClient implements ClientProtocol {
bucket.getQuotaInBytes(),
bucket.getQuotaInNamespace(),
bucket.getBucketLayout(),
- bucket.getOwner()))
+ bucket.getOwner(),
+ bucket.getDefaultReplicationConfig()))
.collect(Collectors.toList());
}
diff --git
a/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/client/rpc/TestOzoneRpcClient.java
b/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/client/rpc/TestOzoneRpcClient.java
index 3e7782d..93ee394 100644
---
a/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/client/rpc/TestOzoneRpcClient.java
+++
b/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/client/rpc/TestOzoneRpcClient.java
@@ -19,14 +19,23 @@
package org.apache.hadoop.ozone.client.rpc;
import java.io.IOException;
+import java.util.Iterator;
+import java.util.UUID;
+import org.apache.hadoop.hdds.client.DefaultReplicationConfig;
+import org.apache.hadoop.hdds.client.ECReplicationConfig;
import org.apache.hadoop.hdds.conf.OzoneConfiguration;
import org.apache.hadoop.hdds.scm.ScmConfigKeys;
import org.apache.hadoop.ozone.OzoneConfigKeys;
+import org.apache.hadoop.ozone.client.BucketArgs;
+import org.apache.hadoop.ozone.client.OzoneBucket;
+import org.apache.hadoop.ozone.client.OzoneVolume;
import org.junit.AfterClass;
+import org.junit.Assert;
import org.junit.BeforeClass;
import org.junit.Rule;
+import org.junit.Test;
import org.junit.rules.Timeout;
@@ -65,4 +74,23 @@ public class TestOzoneRpcClient extends
TestOzoneRpcClientAbstract {
public static void shutdown() throws IOException {
shutdownCluster();
}
+
+ @Test
+ public void testCreateAndListBucketReturnsCorrectRepConfigf()
+ throws Exception {
+ ECReplicationConfig repConfig = new ECReplicationConfig(3, 2);
+ String volumeName = UUID.randomUUID().toString();
+ String bucketName = UUID.randomUUID().toString();
+ getStore().createVolume(volumeName);
+ OzoneVolume volume = getStore().getVolume(volumeName);
+
+ BucketArgs bucketArgs = BucketArgs.newBuilder()
+ .setDefaultReplicationConfig(new DefaultReplicationConfig(repConfig))
+ .build();
+ volume.createBucket(bucketName, bucketArgs);
+
+ Iterator<? extends OzoneBucket> iterator = volume.listBuckets(null);
+ OzoneBucket bucket = iterator.next();
+ Assert.assertEquals(repConfig, bucket.getReplicationConfig());
+ }
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
