TanYuxin-tyx commented on code in PR #22330:
URL: https://github.com/apache/flink/pull/22330#discussion_r1180124978
##########
flink-runtime/src/main/java/org/apache/flink/runtime/shuffle/NettyShuffleMaster.java:
##########
@@ -49,6 +57,10 @@ public class NettyShuffleMaster implements
ShuffleMaster<NettyShuffleDescriptor>
private final int networkBufferSize;
+ private final ResourceRegistry resourceRegistry;
Review Comment:
Added a `TieredInternalShuffleMaster` wrapper class.
All the tiered storage operations with the shuffle master should be wrapped
in this class.
The `ResourceRegistry ` is changed as a variable in the constructor of
`TieredInternalShuffleMaster`.
--
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: issues-unsubscr...@flink.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
