Skip to content

Commit 044ee38

Browse files
committed
Use ConcurrentSet in testTrackingChannelTask (#56775)
We need to use a ConcurrentSet to track the canceled tasks as cancelTaskAndDescendants can be called concurrently. Closes #56746
1 parent ac59026 commit 044ee38

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

server/src/test/java/org/elasticsearch/tasks/TaskManagerTests.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -76,10 +76,9 @@ public void testResultsServiceRetryTotalTime() {
7676
assertEquals(600000L, total);
7777
}
7878

79-
@AwaitsFix(bugUrl = "https://github.com/elastic/elasticsearch/issues/56746")
8079
public void testTrackingChannelTask() throws Exception {
8180
final TaskManager taskManager = new TaskManager(Settings.EMPTY, threadPool, Collections.emptySet());
82-
Set<CancellableTask> cancelledTasks = new HashSet<>();
81+
Set<CancellableTask> cancelledTasks = ConcurrentCollections.newConcurrentSet();
8382
taskManager.setTaskCancellationService(new TaskCancellationService(mock(TransportService.class)) {
8483
@Override
8584
void cancelTaskAndDescendants(CancellableTask task, String reason, boolean waitForCompletion, ActionListener<Void> listener) {

0 commit comments

Comments
 (0)