Apache
/
hadoop
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HDFS-10764. Fix INodeFile#getBlocks to not return null. Contributed by Arpit Agarwal. 

(cherry picked from commit 0faee62a0c)
(cherry picked from commit fff0418458)
This commit is contained in:
Jing Zhao 2016-08-19 22:13:36 -07:00
parent b2efb2040c
commit 8628ad0790
1 changed files with 12 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/INodeFile.java
View File

@ -135,14 +135,14 @@ public class INodeFile extends INodeWithAdditionalFields
super(id, name, permissions, mtime, atime); super(id, name, permissions, mtime, atime);
header = HeaderFormat.toLong(preferredBlockSize, replication, header = HeaderFormat.toLong(preferredBlockSize, replication,
storagePolicyID); storagePolicyID);
this.blocks = blklist; setBlocks(blklist);
} }
public INodeFile(INodeFile that) { public INodeFile(INodeFile that) {
super(that); super(that);
this.header = that.header; this.header = that.header;
this.blocks = that.blocks;
this.features = that.features; this.features = that.features;
setBlocks(that.blocks);
} }
public INodeFile(INodeFile that, FileDiffList diffs) { public INodeFile(INodeFile that, FileDiffList diffs) {
@ -212,9 +212,6 @@ public class INodeFile extends INodeWithAdditionalFields
/** Assert all blocks are complete. */ /** Assert all blocks are complete. */
private void assertAllBlocksComplete(int numCommittedAllowed, private void assertAllBlocksComplete(int numCommittedAllowed,
short minReplication) { short minReplication) {
if (blocks == null) {
return;
}
for (int i = 0; i < blocks.length; i++) { for (int i = 0; i < blocks.length; i++) {
final String err = checkBlockComplete(blocks, i, numCommittedAllowed, final String err = checkBlockComplete(blocks, i, numCommittedAllowed,
minReplication); minReplication);
@ -283,7 +280,7 @@ public class INodeFile extends INodeWithAdditionalFields
BlockInfo removeLastBlock(Block oldblock) { BlockInfo removeLastBlock(Block oldblock) {
Preconditions.checkState(isUnderConstruction(), Preconditions.checkState(isUnderConstruction(),
"file is no longer under construction"); "file is no longer under construction");
if (blocks == null || blocks.length == 0) { if (blocks.length == 0) {
return null; return null;
} }
int size_1 = blocks.length - 1; int size_1 = blocks.length - 1;
@ -501,7 +498,7 @@ public class INodeFile extends INodeWithAdditionalFields
* add a block to the block list * add a block to the block list
*/ */
void addBlock(BlockInfo newblock) { void addBlock(BlockInfo newblock) {
if (this.blocks == null) { if (this.blocks.length == 0) {
this.setBlocks(new BlockInfo[]{newblock}); this.setBlocks(new BlockInfo[]{newblock});
} else { } else {
int size = this.blocks.length; int size = this.blocks.length;
@ -514,12 +511,12 @@ public class INodeFile extends INodeWithAdditionalFields
/** Set the blocks. */ /** Set the blocks. */
private void setBlocks(BlockInfo[] blocks) { private void setBlocks(BlockInfo[] blocks) {
this.blocks = blocks; this.blocks = (blocks != null ? blocks : BlockInfo.EMPTY_ARRAY);
} }
/** Clear all blocks of the file. */ /** Clear all blocks of the file. */
public void clearBlocks() { public void clearBlocks() {
setBlocks(BlockInfo.EMPTY_ARRAY); this.blocks = BlockInfo.EMPTY_ARRAY;
} }
@Override @Override
@ -704,7 +701,7 @@ public class INodeFile extends INodeWithAdditionalFields
*/ */
public final long computeFileSize(boolean includesLastUcBlock, public final long computeFileSize(boolean includesLastUcBlock,
boolean usePreferredBlockSize4LastUcBlock) { boolean usePreferredBlockSize4LastUcBlock) {
if (blocks == null || blocks.length == 0) { if (blocks.length == 0) {
return 0; return 0;
} }
final int last = blocks.length - 1; final int last = blocks.length - 1;
@ -769,7 +766,7 @@ public class INodeFile extends INodeWithAdditionalFields
* Return the penultimate allocated block for this file. * Return the penultimate allocated block for this file.
*/ */
BlockInfo getPenultimateBlock() { BlockInfo getPenultimateBlock() {
if (blocks == null || blocks.length <= 1) { if (blocks.length <= 1) {
return null; return null;
} }
return blocks[blocks.length - 2]; return blocks[blocks.length - 2];
@ -777,12 +774,12 @@ public class INodeFile extends INodeWithAdditionalFields
@Override @Override
public BlockInfo getLastBlock() { public BlockInfo getLastBlock() {
return blocks == null || blocks.length == 0? null: blocks[blocks.length-1]; return blocks.length == 0 ? null: blocks[blocks.length-1];
} }
@Override @Override
public int numBlocks() { public int numBlocks() {
return blocks == null ? 0 : blocks.length; return blocks.length;
} }
@VisibleForTesting @VisibleForTesting
@ -793,7 +790,7 @@ public class INodeFile extends INodeWithAdditionalFields
out.print(", fileSize=" + computeFileSize(snapshotId)); out.print(", fileSize=" + computeFileSize(snapshotId));
// only compare the first block // only compare the first block
out.print(", blocks="); out.print(", blocks=");
out.print(blocks == null || blocks.length == 0? null: blocks[0]); out.print(blocks.length == 0 ? null: blocks[0]);
out.println(); out.println();
} }
@ -838,7 +835,7 @@ public class INodeFile extends INodeWithAdditionalFields
long newLength, BlockStoragePolicy bsps, long newLength, BlockStoragePolicy bsps,
QuotaCounts delta) { QuotaCounts delta) {
final BlockInfo[] blocks = getBlocks(); final BlockInfo[] blocks = getBlocks();
if (blocks == null || blocks.length == 0) { if (blocks.length == 0) {
return; return;
} }