Skip to content

Commit 6e4eca9

Browse files
authored
Fixes bug where failed bulk import status was not cleaned up (apache#5176)
The shell and monitor display active bulk imports and this is driven by custom code in the manager that updates this status as the bulk import runs. When a bulk import fate operation failed it was not clearing this.
1 parent 5cd9c07 commit 6e4eca9

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

server/manager/src/main/java/org/apache/accumulo/manager/tableOps/bulkVer2/PrepBulkImport.java

+1
Original file line numberDiff line numberDiff line change
@@ -323,5 +323,6 @@ public void undo(FateId fateId, Manager environment) throws Exception {
323323
// unreserve sourceDir/error directories
324324
Utils.unreserveHdfsDirectory(environment, bulkInfo.sourceDir, fateId);
325325
Utils.getReadLock(environment, bulkInfo.tableId, fateId).unlock();
326+
environment.removeBulkImportStatus(bulkInfo.sourceDir);
326327
}
327328
}

0 commit comments

Comments
 (0)