Skip to content

Commit 2e13702

Browse files
authored
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 d7735d9 commit 2e13702

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -79,7 +79,7 @@ public void testResultsServiceRetryTotalTime() {
7979
@AwaitsFix(bugUrl = "https://github.com/elastic/elasticsearch/issues/56746")
8080
public void testTrackingChannelTask() throws Exception {
8181
final TaskManager taskManager = new TaskManager(Settings.EMPTY, threadPool, Set.of());
82-
Set<CancellableTask> cancelledTasks = new HashSet<>();
82+
Set<CancellableTask> cancelledTasks = ConcurrentCollections.newConcurrentSet();
8383
taskManager.setTaskCancellationService(new TaskCancellationService(mock(TransportService.class)) {
8484
@Override
8585
void cancelTaskAndDescendants(CancellableTask task, String reason, boolean waitForCompletion, ActionListener<Void> listener) {

0 commit comments

Comments
 (0)