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

HDFS-15143. LocatedStripedBlock returns wrong block type. Contributed by Ayush Saxena.

Browse Source
This commit is contained in:
Ayush Saxena 2020-01-28 19:34:21 +05:30
parent 3f01c48106
commit f876dc228b
2 changed files with 13 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/protocol/LocatedStripedBlock.java
View File

@ -77,6 +77,11 @@ public boolean isStriped() {
return true; return true;
} }
@Override
public BlockType getBlockType() {
return BlockType.STRIPED;
}
public Token<BlockTokenIdentifier>[] getBlockTokens() { public Token<BlockTokenIdentifier>[] getBlockTokens() {
return blockTokens; return blockTokens;
} }

8
hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/util/TestStripedBlockUtil.java
View File

@ -22,6 +22,7 @@
import org.apache.hadoop.fs.StorageType; import org.apache.hadoop.fs.StorageType;
import org.apache.hadoop.hdfs.DFSTestUtil; import org.apache.hadoop.hdfs.DFSTestUtil;
import org.apache.hadoop.hdfs.StripedFileTestUtil; import org.apache.hadoop.hdfs.StripedFileTestUtil;
import org.apache.hadoop.hdfs.protocol.BlockType;
import org.apache.hadoop.hdfs.protocol.DatanodeInfo; import org.apache.hadoop.hdfs.protocol.DatanodeInfo;
import org.apache.hadoop.hdfs.protocol.ExtendedBlock; import org.apache.hadoop.hdfs.protocol.ExtendedBlock;
import org.apache.hadoop.hdfs.protocol.LocatedBlock; import org.apache.hadoop.hdfs.protocol.LocatedBlock;
@ -173,6 +174,13 @@ private byte[][] createInternalBlkBuffers(int bgSize) {
return bufs; return bufs;
} }
@Test
public void testLocatedStripedBlockType() {
LocatedStripedBlock lsb =
new LocatedStripedBlock(null, null, null, null, null, 0, false, null);
assertEquals(BlockType.STRIPED, lsb.getBlockType());
}
@Test @Test
public void testParseDummyStripedBlock() { public void testParseDummyStripedBlock() {
LocatedStripedBlock lsb = createDummyLocatedBlock( LocatedStripedBlock lsb = createDummyLocatedBlock(