Details
-
Sub-task
-
Status: Resolved
-
Minor
-
Resolution: Fixed
-
None
-
None
-
-
Reviewed
Description
- Cancel remaining reads on InterruptedException.
} catch (InterruptedException e) { LOG.info("Read data interrupted.", e); break; }
- Shouldn't fail recontruction due to an IOException errors while reporting corrupt blocks.
} finally { // report corrupted blocks to NN reportCorruptedBlocks(corruptionMap); }
- ECW#closeBlockReader() function can be simplified using IOUtils.closeStream(closable)
- Also, use {} instead of string concatenation in logger.
LOG.debug("Using striped reads; pool threads=" + num); //... LOG.warn("Found Checksum error for " + reader.block + " from " + reader.source + " at " + e.getPos()); //... LOG.debug("Using striped block reconstruction; pool threads=" + num); //.. LOG.warn("Failed to reconstruct striped block: " + blockGroup, e);