runzhiwang edited a comment on pull request #231:
URL: https://github.com/apache/incubator-ratis/pull/231#issuecomment-715370067
@szetszwo There are some clues, I print some message as following.
```
JavaUtils.allOf(remoteWrites).thenCombine(localWrite, (v,
bytesWritten) -> {
System.err.println("dataLength:" + request.getDataLength() + "
bytesWritten:" + bytesWritten);
buf.release();
sendReply(remoteWrites, request, bytesWritten, ctx);
return null;
});
```
```
// check writeAsync requests
for(int i = 0; i < futures.size(); i++) {
final DataStreamReply reply = futures.get(i).join();
Assert.assertTrue(reply.isSuccess());
System.err.println("assert i:" + i + " size:" +
sizes.get(i).longValue() +
" written:" + reply.getBytesWritten() + ", dataLen" +
reply.getDataLength() + ", offset" +
reply.getStreamOffset() + " stream:" + reply.getStreamId());
Assert.assertEquals(sizes.get(i).longValue(), reply.getBytesWritten());
}
```
Following is the print result when test fail, we can find written: 669041 is
the next message of dataLength: 895899, but the assert need they are equal, so
assert fails. some reply was out of order.
```
dataLength:895899 bytesWritten:895899
dataLength:895899 bytesWritten:895899
dataLength:895899 bytesWritten:895899
dataLength:669041 bytesWritten:669041
dataLength:669041 bytesWritten:669041
dataLength:669041 bytesWritten:669041
assert i:6 size:895899 written:669041, dataLen0, offset4837228 stream:1
Error:
testDataStreamMultipleServer(org.apache.ratis.datastream.TestDataStream) Time
elapsed: 0.78 s <<< FAILURE!
java.lang.AssertionError: expected:<895899> but was:<669041>
```
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
[email protected]
