Skip to content

Commit e920687

Browse files
Update server/manager/src/main/java/org/apache/accumulo/manager/tableOps/bulkVer2/LoadFiles.java
Co-authored-by: Daniel Roberts <ddanielr@gmail.com>
1 parent a616266 commit e920687

File tree

1 file changed

+4
-4
lines changed
  • server/manager/src/main/java/org/apache/accumulo/manager/tableOps/bulkVer2

1 file changed

+4
-4
lines changed

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

+4-4
Original file line numberDiff line numberDiff line change
@@ -215,10 +215,10 @@ private void sendQueued(int threshhold) {
215215
tabletFiles.values().stream().mapToInt(Map::size).sum(), tabletFiles.size());
216216
}
217217

218-
// On the server side tablets are processed serially with a write to the metadata table
219-
// done for each tablet. Chunk the work up for a tablet server up so that it can be sent
220-
// over multiple connections allowing it to run in parallel on the server side. This
221-
// allows multiple threads on a single tserver to do metadata writes for this bulk
218+
// Tablet servers process tablets serially and perform a single metadata table write for each tablet.
219+
// Break the work into per-tablet chunks so it can be sent over multiple connections
220+
// to the tserver, allowing each chunk to be run in parallel on the server side.
221+
// This allows multiple threads on a single tserver to do metadata writes for this bulk
222222
// import.
223223
int neededConnections = Math.min(maxConnections, tabletFiles.size());
224224
List<Map<TKeyExtent,Map<String,MapFileInfo>>> chunks =

0 commit comments

Comments
 (0)