[
https://issues.apache.org/jira/browse/HDDS-5685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17405560#comment-17405560
]
Tsz-wo Sze commented on HDDS-5685:
----------------------------------
Regardless of topology, both the local and remote writes are submitted as async
tasks, i.e. the won't wait for each others. See DataStreamManagement.read(..).
{code}
//DataStreamManagement.java
void read(DataStreamRequestByteBuf request, ChannelHandlerContext ctx,
CheckedBiFunction<RaftClientRequest, Set<RaftPeer>,
Set<DataStreamOutputRpc>, IOException> getStreams) {
LOG.debug("{}: read {}", this, request);
...
} else if (request.getType() == Type.STREAM_DATA) {
localWrite = info.getLocal().write(buf, request.getWriteOptions(),
writeExecutor);
remoteWrites = info.applyToRemotes(out -> out.write(request,
requestExecutor));
} else {
...
composeAsync(info.getPrevious(), requestExecutor, n ->
JavaUtils.allOf(remoteWrites)
.thenCombineAsync(localWrite, (v, bytesWritten) -> {
...
}
{code}
> Ozone Streaming Performance test.
> ---------------------------------
>
> Key: HDDS-5685
> URL: https://issues.apache.org/jira/browse/HDDS-5685
> Project: Apache Ozone
> Issue Type: Sub-task
> Reporter: mingchao zhao
> Assignee: mingchao zhao
> Priority: Major
> Attachments: image-2021-08-27-11-07-36-526.png
>
>
> We can test and discuss the performance of Ozone Streaming under this JIRA.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
