chungen0126 commented on code in PR #10765:
URL: https://github.com/apache/ozone/pull/10765#discussion_r3596151743
##########
hadoop-hdds/client/src/main/java/org/apache/hadoop/hdds/scm/storage/BlockInputStream.java:
##########
@@ -108,6 +110,10 @@ public class BlockInputStream extends
BlockExtendedInputStream {
private BlockData blockData;
+ private Pipeline failedPipeline;
Review Comment:
The reason I track previously failed pipelines is that, in my design, I
assume a scenario where multiple position read in `BlockInputStream` might fail
concurrently and attempt to refresh the block info at the same time. Once the
first `BlockInputStream` completes the refresh, subsequent streams will obtain
the updated information. If the position read detects that its failed pipeline
belongs to the old one and a new pipeline is now available, it should not need
to trigger another redundant refresh.
--
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]
