dlmarion commented on a change in pull request #2128:
URL: https://github.com/apache/accumulo/pull/2128#discussion_r643963906
##########
File path:
server/tserver/src/main/java/org/apache/accumulo/tserver/compactions/ExternalCompactionExecutor.java
##########
@@ -190,10 +190,10 @@ ExternalCompactionJob reserveExternalCompaction(long
priority, String compactorI
}
public Stream<TCompactionQueueSummary> summarize() {
- HashSet<Long> uniqPrios = new HashSet<Long>();
+ HashSet<Short> uniqPrios = new HashSet<Short>();
queuedTask.forEach(task -> uniqPrios.add(task.getJob().getPriority()));
- Stream<Long> prioStream = uniqPrios.stream();
+ Stream<Short> prioStream = uniqPrios.stream();
if (uniqPrios.size() > 100) {
// Until #2094 is addressed limit what is sent to the coordinator to
avoid causing it run out
Review comment:
I updated the comment in 2d548ab550a2fe3df661d37cb7a120b015014294 to
remove the reference to the issue number. I did leave in place the 100 limit.
--
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.
For queries about this service, please contact Infrastructure at:
[email protected]
