big-data/hadoop
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

HDFS-12635. Unnecessary exception declaration of the CellBuffers constructor. Contributed by Huafeng Wang

Browse Source
This commit is contained in:
Kai Zheng 2017-10-11 15:45:28 +08:00
parent 3d04c00aed
commit d8d37b63c7
1 changed files with 2 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/DFSStripedOutputStream.java
View File

@ -198,7 +198,7 @@ class CellBuffers {
private final ByteBuffer[] buffers; private final ByteBuffer[] buffers;
private final byte[][] checksumArrays; private final byte[][] checksumArrays;
CellBuffers(int numParityBlocks) throws InterruptedException{ CellBuffers(int numParityBlocks) {
if (cellSize % bytesPerChecksum != 0) { if (cellSize % bytesPerChecksum != 0) {
throw new HadoopIllegalArgumentException("Invalid values: " throw new HadoopIllegalArgumentException("Invalid values: "
+ HdfsClientConfigKeys.DFS_BYTES_PER_CHECKSUM_KEY + " (=" + HdfsClientConfigKeys.DFS_BYTES_PER_CHECKSUM_KEY + " (="
@ -304,12 +304,7 @@ private void flipDataBuffers() {
ecPolicy.getCodecName(), coderOptions); ecPolicy.getCodecName(), coderOptions);
coordinator = new Coordinator(numAllBlocks); coordinator = new Coordinator(numAllBlocks);
try {
cellBuffers = new CellBuffers(numParityBlocks); cellBuffers = new CellBuffers(numParityBlocks);
} catch (InterruptedException ie) {
throw DFSUtilClient.toInterruptedIOException(
"Failed to create cell buffers", ie);
}
streamers = new ArrayList<>(numAllBlocks); streamers = new ArrayList<>(numAllBlocks);
for (short i = 0; i < numAllBlocks; i++) { for (short i = 0; i < numAllBlocks; i++) {