[accumulo] branch main updated: fixes bulk import filename prefix (#3477)

[kturner]

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 <ktur...@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());
     }