Skip to content

Commit c4faf5d

Browse files
committed
MAPREDUCE-7474. Manifest committer resilience: test failure
Change-Id: I039ec6e4dc12f68690ffa977ebb81056ab0d1711
1 parent e6126c1 commit c4faf5d

File tree

3 files changed

+3
-3
lines changed

3 files changed

+3
-3
lines changed

hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/lib/output/committer/manifest/impl/ManifestStoreOperations.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -109,7 +109,7 @@ public abstract boolean delete(Path path, boolean recursive)
109109
*/
110110
public boolean deleteFile(Path path)
111111
throws IOException {
112-
return delete(path, true);
112+
return delete(path, false);
113113
}
114114

115115
/**

hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/lib/output/committer/manifest/stages/AbstractJobOrTaskStage.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -746,7 +746,7 @@ protected boolean storeSupportsResilientCommit() {
746746
*/
747747
private void maybeDeleteDest(final boolean deleteDest, final Path dest) throws IOException {
748748

749-
if (deleteDest && getFileStatusOrNull(dest) != null) {
749+
if (deleteDest) {
750750
final FileStatus st = getFileStatusOrNull(dest);
751751
if (st != null) {
752752
if (st.isDirectory()) {

hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/test/java/org/apache/hadoop/mapreduce/lib/output/committer/manifest/TestCreateOutputDirectoriesStage.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -247,7 +247,7 @@ public void testPrepareDirtyTree() throws Throwable {
247247
CreateOutputDirectoriesStage attempt2 =
248248
new CreateOutputDirectoriesStage(
249249
createStageConfigForJob(JOB1, destDir)
250-
.withDeleteTargetPaths(true));
250+
.withDeleteTargetPaths(false));
251251
// attempt will fail because one of the entries marked as
252252
// a file to delete is now a non-empty directory
253253
LOG.info("Executing failing attempt to create the directories");

0 commit comments

Comments
 (0)