This is an automated email from the ASF dual-hosted git repository.
karan pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/druid.git
The following commit(s) were added to refs/heads/master by this push:
new bedf246ed26 Fixing 1 flaky test in testAPIs() (#15375)
bedf246ed26 is described below
commit bedf246ed26f8118fe9cf0cddbe5770da6ce9075
Author: Krishna Anandan <[email protected]>
AuthorDate: Wed Nov 15 07:08:20 2023 -0600
Fixing 1 flaky test in testAPIs() (#15375)
---
.../batch/parallel/ParallelIndexSupervisorTaskResourceTest.java | 6 +++++-
1 file changed, 5 insertions(+), 1 deletion(-)
diff --git
a/indexing-service/src/test/java/org/apache/druid/indexing/common/task/batch/parallel/ParallelIndexSupervisorTaskResourceTest.java
b/indexing-service/src/test/java/org/apache/druid/indexing/common/task/batch/parallel/ParallelIndexSupervisorTaskResourceTest.java
index b11d939f760..4ee422a0414 100644
---
a/indexing-service/src/test/java/org/apache/druid/indexing/common/task/batch/parallel/ParallelIndexSupervisorTaskResourceTest.java
+++
b/indexing-service/src/test/java/org/apache/druid/indexing/common/task/batch/parallel/ParallelIndexSupervisorTaskResourceTest.java
@@ -66,6 +66,7 @@ import javax.ws.rs.core.Response;
import java.util.ArrayList;
import java.util.Collection;
import java.util.Collections;
+import java.util.Comparator;
import java.util.HashMap;
import java.util.HashSet;
import java.util.List;
@@ -337,11 +338,14 @@ public class ParallelIndexSupervisorTaskResourceTest
extends AbstractParallelInd
.stream()
.filter(entry -> !runningSpecs.containsKey(entry.getKey()))
.map(entry -> entry.getValue().getSpec())
+ .sorted(Comparator.comparing(SubTaskSpec::getId))
.collect(Collectors.toList());
response = task.getCompleteSubTaskSpecs(newRequest());
Assert.assertEquals(200, response.getStatus());
- Assert.assertEquals(completeSubTaskSpecs, response.getEntity());
+ List<SubTaskSpec<SinglePhaseSubTask>> actual =
(List<SubTaskSpec<SinglePhaseSubTask>>) response.getEntity();
+ actual.sort(Comparator.comparing(SubTaskSpec::getId));
+ Assert.assertEquals(completeSubTaskSpecs, actual);
// subTaskSpec
final String subTaskId = runningSpecs.keySet().iterator().next();
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
