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

MAPREDUCE-6676. NNBench should Throw IOException when rename and delete fails. Contributed by Brahma Reddy Battula.

This commit is contained in:
Brahma Reddy Battula 2017-06-07 16:34:47 +08:00 committed by Xiaoyu Yao
parent 0887355d9c
commit bea02d229c
1 changed files with 8 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-jobclient/src/test/java/org/apache/hadoop/hdfs/NNBench.java
View File

@ -868,7 +868,10 @@ public class NNBench extends Configured implements Tool {
try { try {
// Set up timer for measuring AL // Set up timer for measuring AL
startTimeAL = System.currentTimeMillis(); startTimeAL = System.currentTimeMillis();
filesystem.rename(filePath, filePathR); boolean result = filesystem.rename(filePath, filePathR);
if (!result) {
throw new IOException("rename failed for " + filePath);
}
totalTimeAL1 += (System.currentTimeMillis() - startTimeAL); totalTimeAL1 += (System.currentTimeMillis() - startTimeAL);
successfulOp = true; successfulOp = true;
@ -901,7 +904,10 @@ public class NNBench extends Configured implements Tool {
try { try {
// Set up timer for measuring AL // Set up timer for measuring AL
startTimeAL = System.currentTimeMillis(); startTimeAL = System.currentTimeMillis();
filesystem.delete(filePath, true); boolean result = filesystem.delete(filePath, true);
if (!result) {
throw new IOException("delete failed for " + filePath);
}
totalTimeAL1 += (System.currentTimeMillis() - startTimeAL); totalTimeAL1 += (System.currentTimeMillis() - startTimeAL);
successfulOp = true; successfulOp = true;