You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by su...@apache.org on 2017/10/12 09:38:02 UTC
[35/50] [abbrv] hadoop git commit: HDFS-12635. Unnecessary exception
declaration of the CellBuffers constructor. Contributed by Huafeng Wang
HDFS-12635. Unnecessary exception declaration of the CellBuffers constructor. Contributed by Huafeng Wang
Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/d8d37b63
Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/d8d37b63
Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/d8d37b63
Branch: refs/heads/YARN-5881
Commit: d8d37b63c71ff4ae0a15d9eb51a9436605ac1a52
Parents: 3d04c00
Author: Kai Zheng <ka...@intel.com>
Authored: Wed Oct 11 15:45:28 2017 +0800
Committer: Kai Zheng <ka...@intel.com>
Committed: Wed Oct 11 15:45:28 2017 +0800
----------------------------------------------------------------------
.../java/org/apache/hadoop/hdfs/DFSStripedOutputStream.java | 9 ++-------
1 file changed, 2 insertions(+), 7 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hadoop/blob/d8d37b63/hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/DFSStripedOutputStream.java
----------------------------------------------------------------------
diff --git a/hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/DFSStripedOutputStream.java b/hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/DFSStripedOutputStream.java
index 66eec7a..3eb7e67 100644
--- a/hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/DFSStripedOutputStream.java
+++ b/hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/DFSStripedOutputStream.java
@@ -198,7 +198,7 @@ public class DFSStripedOutputStream extends DFSOutputStream
private final ByteBuffer[] buffers;
private final byte[][] checksumArrays;
- CellBuffers(int numParityBlocks) throws InterruptedException{
+ CellBuffers(int numParityBlocks) {
if (cellSize % bytesPerChecksum != 0) {
throw new HadoopIllegalArgumentException("Invalid values: "
+ HdfsClientConfigKeys.DFS_BYTES_PER_CHECKSUM_KEY + " (="
@@ -304,12 +304,7 @@ public class DFSStripedOutputStream extends DFSOutputStream
ecPolicy.getCodecName(), coderOptions);
coordinator = new Coordinator(numAllBlocks);
- try {
- cellBuffers = new CellBuffers(numParityBlocks);
- } catch (InterruptedException ie) {
- throw DFSUtilClient.toInterruptedIOException(
- "Failed to create cell buffers", ie);
- }
+ cellBuffers = new CellBuffers(numParityBlocks);
streamers = new ArrayList<>(numAllBlocks);
for (short i = 0; i < numAllBlocks; i++) {
---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-commits-help@hadoop.apache.org