Fix infinite loop in RegionFile IO
If an exception is thrown during decompress then the read process would be started again, which of course would eventually throw in the decompress process.
This commit is contained in:
@@ -1143,7 +1143,7 @@ public final class MoonriseRegionFileIO {
|
||||
LOGGER.error("Failed to decompress chunk data for task: " + this.toString(), thr);
|
||||
}
|
||||
|
||||
if (compoundTag == null) {
|
||||
if (throwable == null && compoundTag == null) {
|
||||
// need to re-try from the start
|
||||
this.scheduleReadIO();
|
||||
return;
|
||||
|
||||
Reference in New Issue
Block a user