You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by kt...@apache.org on 2023/06/09 17:17:50 UTC
[accumulo] branch main updated: fixes bulk import filename prefix (#3477)
This is an automated email from the ASF dual-hosted git repository.
kturner pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/accumulo.git
The following commit(s) were added to refs/heads/main by this push:
new 97a11ba820 fixes bulk import filename prefix (#3477)
97a11ba820 is described below
commit 97a11ba8201bbd828dadab75c3835f009604e7ef
Author: Keith Turner <kt...@apache.org>
AuthorDate: Fri Jun 9 13:17:44 2023 -0400
fixes bulk import filename prefix (#3477)
Before this change bulk import files ended up with a name like
BULK_IMPORT000008h.rf after this change the name would be I000008h.rf
instead.
---
.../org/apache/accumulo/manager/tableOps/bulkVer2/PrepBulkImport.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/server/manager/src/main/java/org/apache/accumulo/manager/tableOps/bulkVer2/PrepBulkImport.java b/server/manager/src/main/java/org/apache/accumulo/manager/tableOps/bulkVer2/PrepBulkImport.java
index 4514b98c1a..2b8788f887 100644
--- a/server/manager/src/main/java/org/apache/accumulo/manager/tableOps/bulkVer2/PrepBulkImport.java
+++ b/server/manager/src/main/java/org/apache/accumulo/manager/tableOps/bulkVer2/PrepBulkImport.java
@@ -242,7 +242,7 @@ public class PrepBulkImport extends ManagerRepo {
for (FileStatus file : files) {
// since these are only valid files we know it has an extension
- String newName = FilePrefix.BULK_IMPORT + namer.getNextName() + "."
+ String newName = FilePrefix.BULK_IMPORT.toPrefix() + namer.getNextName() + "."
+ FilenameUtils.getExtension(file.getPath().getName());
oldToNewNameMap.put(file.getPath().getName(), new Path(bulkDir, newName).getName());
}