umamaheswararao commented on code in PR #3460:
URL: https://github.com/apache/ozone/pull/3460#discussion_r886043704
##########
hadoop-ozone/client/src/test/java/org/apache/hadoop/ozone/client/TestOzoneECClient.java:
##########
@@ -814,6 +816,64 @@ public void testNodeFailuresWhileWriting(int[]
nodesIndexesToMarkFailure,
}
}
+ @Test
+ public void testExcludeOnDNFailure() throws IOException {
+ testExcludeFailedDN(IntStream.range(0, 5), IntStream.empty());
+ }
+
+ @Test
+ public void testExcludeOnDNClosed() throws IOException {
+ testExcludeFailedDN(IntStream.empty(), IntStream.range(0, 5));
+ }
+
+ @Test
+ public void testExcludeOnDNMixed() throws IOException {
+ testExcludeFailedDN(IntStream.range(0, 3), IntStream.range(3, 5));
+ }
+
+ private void testExcludeFailedDN(IntStream failedDNIndex,
+ IntStream closedDNIndex) throws IOException {
+
+ store.createVolume(volumeName);
+ OzoneVolume volume = store.getVolume(volumeName);
+ volume.createBucket(bucketName);
+ OzoneBucket bucket = volume.getBucket(bucketName);
+
+ ECReplicationConfig repConfig = new ECReplicationConfig(
+ dataBlocks, parityBlocks, ECReplicationConfig.EcCodec.RS, chunkSize);
+
+ try (OzoneOutputStream out = bucket.createKey(keyName,
+ (long) dataBlocks * chunkSize, repConfig, new HashMap<>())) {
+
+ Assert.assertTrue(out.getOutputStream() instanceof ECKeyOutputStream);
+ ECKeyOutputStream ecKeyOut = (ECKeyOutputStream) out.getOutputStream();
+
+ List<HddsProtos.DatanodeDetailsProto> dns = allocator.getClusterDns();
Review Comment:
This test using default initialized Allocator. One we marked some nodes
failed, they may be reflected to other tests.
It would be good to have own allocator and client created for the failure
related tests, so that state would not interfere with others.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
