Update the solution when a file cannot be located. (#5223)
Change the solution when a file cannot be located.
This commit is contained in:
@@ -69,7 +69,7 @@ public class SeaweedRead {
|
|||||||
if (locations == null || locations.getLocationsCount() == 0) {
|
if (locations == null || locations.getLocationsCount() == 0) {
|
||||||
LOG.error("failed to locate {}", chunkView.fileId);
|
LOG.error("failed to locate {}", chunkView.fileId);
|
||||||
volumeIdCache.clearLocations(volumeId);
|
volumeIdCache.clearLocations(volumeId);
|
||||||
return 0;
|
throw new IOException("failed to locate file");
|
||||||
}
|
}
|
||||||
|
|
||||||
int len = readChunkView(filerClient, startOffset, buf, chunkView, locations);
|
int len = readChunkView(filerClient, startOffset, buf, chunkView, locations);
|
||||||
|
|||||||
Reference in New Issue
Block a user