keith-turner commented on issue #5524:
URL: https://github.com/apache/accumulo/issues/5524#issuecomment-2916848190
> It seems bulk import is done in by
org.apache.accumulo.server.fs.VolumeManager implementation, which is
VolumeManagerImpl.
That is the code that needs to change. Could possibly add a method like the
following where the executor service is passed in.
```java
public void bulkRename(Map<Path,Path> oldToNewPathMap, ExecutorService
workerPool,
FateId fateId) throws IOException {
List<Future<Void>> results = new ArrayList<>();
oldToNewPathMap.forEach((oldPath, newPath) ->
results.add(workerPool.submit(() -> {
...
}
```
> Hello @keith-turner,
It looks like Threads pool of size manager.rename.threadpool.size is created
for every bulk rename operation.
As far as I understand we want to have a single Threads pool for all bulk
rename operations.
Correct. Could use that property to create a single executor service for
the manager process and then pass that service to the bulk rename method.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
