jojochuang commented on code in PR #7221:
URL: https://github.com/apache/ozone/pull/7221#discussion_r1768065405
##########
hadoop-hdds/client/src/main/java/org/apache/hadoop/hdds/scm/storage/MultipartInputStream.java:
##########
@@ -173,6 +178,28 @@ public synchronized void seek(long pos) throws IOException
{
prevPartIndex = partIndex;
}
+ public synchronized void initialize() throws IOException {
Review Comment:
For the HBase replication case, the application expects the input stream to
read until the hsync length returned by output stream before the input stream
instantiates. So for your case the read shouldn't read beyond 80 bytes. And
therefore, new blocks added by the writer shouldn't matter either.
--
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]
