This is an automated email from the ASF dual-hosted git repository.
kfaraz 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 f907fb29228 Fixed nondeterministic KinesisSupervisorTest (#18617)
f907fb29228 is described below
commit f907fb2922856e9a49fc82c01881d5a4872481c6
Author: Edwin Ing <[email protected]>
AuthorDate: Fri Oct 10 00:47:00 2025 -0500
Fixed nondeterministic KinesisSupervisorTest (#18617)
---
.../druid/indexing/kinesis/supervisor/KinesisSupervisorTest.java | 9 +++++++--
1 file changed, 7 insertions(+), 2 deletions(-)
diff --git
a/extensions-core/kinesis-indexing-service/src/test/java/org/apache/druid/indexing/kinesis/supervisor/KinesisSupervisorTest.java
b/extensions-core/kinesis-indexing-service/src/test/java/org/apache/druid/indexing/kinesis/supervisor/KinesisSupervisorTest.java
index d24c309e7c8..ea528a68a01 100644
---
a/extensions-core/kinesis-indexing-service/src/test/java/org/apache/druid/indexing/kinesis/supervisor/KinesisSupervisorTest.java
+++
b/extensions-core/kinesis-indexing-service/src/test/java/org/apache/druid/indexing/kinesis/supervisor/KinesisSupervisorTest.java
@@ -106,6 +106,7 @@ import javax.annotation.Nullable;
import java.util.ArrayList;
import java.util.Collection;
import java.util.Collections;
+import java.util.Comparator;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
@@ -603,7 +604,9 @@ public class KinesisSupervisorTest extends EasyMockSupport
supervisor.runInternal();
verifyAll();
- KinesisIndexTask task1 = captured.getValues().get(0);
+ List<KinesisIndexTask> tasks = captured.getValues();
+ tasks.sort(Comparator.comparing(KinesisIndexTask::getId));
+ KinesisIndexTask task1 = tasks.get(0);
Assert.assertEquals(1,
task1.getIOConfig().getStartSequenceNumbers().getPartitionSequenceNumberMap().size());
Assert.assertEquals(1,
task1.getIOConfig().getEndSequenceNumbers().getPartitionSequenceNumberMap().size());
Assert.assertEquals(
@@ -615,7 +618,7 @@ public class KinesisSupervisorTest extends EasyMockSupport
task1.getIOConfig().getEndSequenceNumbers().getPartitionSequenceNumberMap().get(SHARD_ID1)
);
- KinesisIndexTask task2 = captured.getValues().get(1);
+ KinesisIndexTask task2 = tasks.get(1);
Assert.assertEquals(1,
task2.getIOConfig().getStartSequenceNumbers().getPartitionSequenceNumberMap().size());
Assert.assertEquals(1,
task2.getIOConfig().getEndSequenceNumbers().getPartitionSequenceNumberMap().size());
Assert.assertEquals(
@@ -4421,6 +4424,7 @@ public class KinesisSupervisorTest extends EasyMockSupport
.times(1);
List<Task> postSplitTasks = postSplitCaptured.getValues();
+ postSplitTasks.sort(Comparator.comparing(Task::getId));
EasyMock.expect(taskQueue.getActiveTasksForDatasource(DATASOURCE)).andReturn(toMap(postSplitTasks)).anyTimes();
for (Task task : postSplitTasks) {
EasyMock.expect(taskStorage.getStatus(task.getId()))
@@ -4608,6 +4612,7 @@ public class KinesisSupervisorTest extends EasyMockSupport
.times(1);
List<Task> postSplitTasks = postSplitCaptured.getValues();
+ postSplitTasks.sort(Comparator.comparing(Task::getId));
EasyMock.expect(taskQueue.getActiveTasksForDatasource(DATASOURCE)).andReturn(toMap(postSplitTasks)).anyTimes();
for (Task task : postSplitTasks) {
EasyMock.expect(taskStorage.getStatus(task.getId()))
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
