HDDS-1753. Datanode unable to find chunk while replication data using ratis.#1318
HDDS-1753. Datanode unable to find chunk while replication data using ratis.#1318lokeshj1703 merged 3 commits intoapache:trunkfrom
Conversation
|
💔 -1 overall
This message was automatically generated. |
There was a problem hiding this comment.
@bshashikant Thanks for working on this! The changes look good to me. I have couple of minor comments. There are a few checkstyle issues and test failures seem related.
There was a problem hiding this comment.
We can directly use the getServer().getGroupInfo(..) api here and do not need the while loop.
|
💔 -1 overall
This message was automatically generated. |
|
💔 -1 overall
This message was automatically generated. |
|
💔 -1 overall
This message was automatically generated. |
|
💔 -1 overall
This message was automatically generated. |
lokeshj1703
left a comment
There was a problem hiding this comment.
There are a few checkstyle issues. TestBlockDeletion failure seems related.
| XceiverServerRatis ratisServer = | ||
| (XceiverServerRatis) ozoneContainer.getWriteChannel(); | ||
| long minReplicatedIndex = ratisServer.getMinReplicatedIndex(PipelineID | ||
| .valueOf(UUID.fromString(containerData.getOriginPipelineId()))); |
There was a problem hiding this comment.
If the pipeline does not exist, it should throw GroupMismatchException here. We can check what exception is thrown once. In that case we need to return true.
There was a problem hiding this comment.
Addressed in the latest patch.
| Mockito.when(ozoneContainer.getContainerSet()) | ||
| .thenReturn(containerSet); | ||
| Mockito.when(ozoneContainer.getWriteChannel()) | ||
| .thenReturn(null); |
There was a problem hiding this comment.
Since it is used in all the test classes, we can add the logic for mocking ozoneContainer in a TestUtil class.
There was a problem hiding this comment.
Addressed in the latest patch.
| cluster.shutdownHddsDatanode(follower.getDatanodeDetails()); | ||
| key.write(testData); | ||
| key.close(); | ||
| XceiverClientSpi xceiverClient = |
There was a problem hiding this comment.
Can we please add a comment here that the container will be closed? Similarly a comment regarding deleting the key just so that we can separate the various sections of the test.
There was a problem hiding this comment.
addressed in the latest patch..
|
@bshashikant Thanks for updating the PR! The changes look good to me. +1. |
|
💔 -1 overall
This message was automatically generated. |
|
@bshashikant Thanks for working on the PR! I have merged it with trunk. |
No description provided.