Skip to content

Commit

Permalink
fix javadoc warnings
Browse files Browse the repository at this point in the history
Signed-off-by: Kaushal Kumar <ravi.kaushal97@gmail.com>
  • Loading branch information
kaushalmahi12 committed Jun 21, 2024
1 parent bd55e42 commit 0e38dee
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -256,9 +256,9 @@ void doRun() {
/**
* Had to define this method to help mock this static method to test the scenario where SearchTraffic should not be
* penalised when not breaching the threshold
* @param searchTasks
* @param threshold
* @return
* @param searchTasks inFlight co-ordinator requests
* @param threshold miniumum jvm allocated bytes ratio w.r.t. available heap
* @return a boolean value based on whether the threshold is breached
*/
boolean isHeapUsageDominatedBySearch(List<CancellableTask> searchTasks, double threshold) {
return HeapUsageTracker.isHeapUsageDominatedBySearch(searchTasks, threshold);
Expand Down Expand Up @@ -299,8 +299,8 @@ private List<TaskCancellation> addResourceTrackerBasedCancellations(

/**
* Method to reduce the taskCancellations into unique bunch
* @param taskCancellations
* @return
* @param taskCancellations all task cancellations
* @return unique task cancellations
*/
private List<TaskCancellation> mergeTaskCancellations(final List<TaskCancellation> taskCancellations) {
final Map<Long, TaskCancellation> uniqueTaskCancellations = new HashMap<>();
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -111,7 +111,7 @@ public Optional<TaskCancellation.Reason> checkAndMaybeGetCancellationReason(Task
/**
* Method to get taskCancellations due to this tracker for the given {@link CancellableTask} tasks
* @param tasks cancellation eligible tasks due to node duress and search traffic threshold breach
* @return
* @return the list of tasks which are breaching task level thresholds for this {@link TaskResourceUsageTracker}
*/
public List<TaskCancellation> getTaskCancellations(List<CancellableTask> tasks) {
return tasks.stream()
Expand Down

0 comments on commit 0e38dee

Please sign in to comment.