This is an automated email from the ASF dual-hosted git repository.
dineshc pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hadoop-ozone.git
The following commit(s) were added to refs/heads/master by this push:
new 383b078 HDDS-3550. Fix TestReadRetries. (#979)
383b078 is described below
commit 383b0787cdb4148f599878c337cff16088d6442a
Author: bshashikant <[email protected]>
AuthorDate: Fri May 29 07:46:37 2020 +0530
HDDS-3550. Fix TestReadRetries. (#979)
---
.../apache/hadoop/ozone/client/rpc/TestReadRetries.java | 17 +++++------------
1 file changed, 5 insertions(+), 12 deletions(-)
diff --git
a/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/client/rpc/TestReadRetries.java
b/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/client/rpc/TestReadRetries.java
index 01ec892..8c187f4 100644
---
a/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/client/rpc/TestReadRetries.java
+++
b/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/client/rpc/TestReadRetries.java
@@ -95,10 +95,12 @@ public class TestReadRetries {
OzoneConfiguration conf = new OzoneConfiguration();
conf.setInt(ScmConfigKeys.OZONE_SCM_PIPELINE_OWNER_CONTAINER_COUNT, 1);
cluster = MiniOzoneCluster.newBuilder(conf)
- .setNumDatanodes(10)
+ .setNumDatanodes(3)
.setScmId(SCM_ID)
.build();
cluster.waitForClusterToBeReady();
+ cluster.waitForPipelineTobeReady(HddsProtos.ReplicationFactor.THREE,
+ 180000);
ozClient = OzoneClientFactory.getRpcClient(conf);
store = ozClient.getObjectStore();
storageContainerLocationClient =
@@ -184,22 +186,13 @@ public class TestReadRetries {
ratisClient.watchForCommit(keyInfo.getBlockCommitSequenceId());
// shutdown the datanode
cluster.shutdownHddsDatanode(datanodeDetails);
-
- Assert.assertTrue(container.getState()
- == HddsProtos.LifeCycleState.OPEN);
- // try to read, this shouls be successful
+ // try to read, this should be successful
readKey(bucket, keyName, value);
-
- Assert.assertTrue(container.getState()
- == HddsProtos.LifeCycleState.OPEN);
// shutdown the second datanode
datanodeDetails = datanodes.get(1);
cluster.shutdownHddsDatanode(datanodeDetails);
- Assert.assertTrue(container.getState()
- == HddsProtos.LifeCycleState.OPEN);
- // the container is open and with loss of 2 nodes we still should be able
- // to read via Standalone protocol
+ // we still should be able to read via Standalone protocol
// try to read
readKey(bucket, keyName, value);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
