Skip to content

Commit

Permalink
[SMALLFIX] Fix Alluxio/Community#624
Browse files Browse the repository at this point in the history
Fixes Alluxio/Community#624
Alluxio/Community#624

pr-link: Alluxio#16871
change-id: cid-1c61908eb034cdb6d84b5510798ac8c2c7c029e9
  • Loading branch information
nand-porko authored Feb 21, 2023
1 parent 817a3c4 commit d28e933
Showing 1 changed file with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -125,7 +125,7 @@ public BlockInStream getInStream(long blockId, InStreamOptions options) throws I
*
* @param blockId the id of the block to read
* @param options the options associated with the read request
* @param failedWorkers the map of workers addresses to most recent failure time
* @param failedWorkers the map of worker's addresses to most recent failure time
* @return a stream which reads from the beginning of the block
*/
public BlockInStream getInStream(long blockId, InStreamOptions options,
Expand All @@ -140,7 +140,7 @@ public BlockInStream getInStream(long blockId, InStreamOptions options,
*
* @param info the block info
* @param options the options associated with the read request
* @param failedWorkers the map of workers addresses to most recent failure time
* @param failedWorkers the map of worker's addresses to most recent failure time
* @return a stream which reads from the beginning of the block
*/
public BlockInStream getInStream(BlockInfo info, InStreamOptions options,
Expand Down Expand Up @@ -169,7 +169,7 @@ public BlockInStream getInStream(BlockInfo info, InStreamOptions options,
* @param info the info of the block to read
* @param status the URIStatus associated with the read request
* @param policy the policy determining the Alluxio worker location
* @param failedWorkers the map of workers addresses to most recent failure time
* @param failedWorkers the map of worker's addresses to most recent failure time
* @return the data source and type of data source of the block
*/
public Pair<WorkerNetAddress, BlockInStreamSource> getDataSourceAndType(BlockInfo info,
Expand Down

0 comments on commit d28e933

Please sign in to comment.