keith-turner commented on code in PR #4767:
URL: https://github.com/apache/accumulo/pull/4767#discussion_r1693593268
##########
server/manager/src/main/java/org/apache/accumulo/manager/compaction/queue/CompactionJobPriorityQueue.java:
##########
@@ -304,4 +309,8 @@ private CjpqKey addJobToQueue(TabletMetadata
tabletMetadata, CompactionJob job)
jobQueue.put(key, new CompactionJobQueues.MetaJob(job, tabletMetadata));
return key;
}
+
+ public synchronized void clear() {
+ jobQueue.clear();
Review Comment:
tabletJobs needs to be cleared also, its like an index for jobQueue that
helps quickly find what a tablet has queued in jobQueue
```suggestion
jobQueue.clear();
tabletJobs.clear();
```
--
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]
