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 33f7f778dfc ci: Fix SupervisorManagerTest (#20294)
33f7f778dfc is described below
commit 33f7f778dfc2d8b06ca7c1d7a93f54f162526cee
Author: Kashif Faraz <[email protected]>
AuthorDate: Tue Sep 8 15:54:29 2026 +0530
ci: Fix SupervisorManagerTest (#20294)
---
.../overlord/supervisor/SupervisorManagerTest.java | 17 +++++++++--------
1 file changed, 9 insertions(+), 8 deletions(-)
diff --git
a/indexing-service/src/test/java/org/apache/druid/indexing/overlord/supervisor/SupervisorManagerTest.java
b/indexing-service/src/test/java/org/apache/druid/indexing/overlord/supervisor/SupervisorManagerTest.java
index 7fe9a0ad80b..a93686972a1 100644
---
a/indexing-service/src/test/java/org/apache/druid/indexing/overlord/supervisor/SupervisorManagerTest.java
+++
b/indexing-service/src/test/java/org/apache/druid/indexing/overlord/supervisor/SupervisorManagerTest.java
@@ -32,6 +32,7 @@ import org.apache.druid.data.input.impl.ByteEntity;
import org.apache.druid.data.input.impl.DimensionsSpec;
import org.apache.druid.data.input.impl.TimestampSpec;
import org.apache.druid.error.DruidException;
+import org.apache.druid.error.DruidExceptionMatcher;
import org.apache.druid.error.InvalidInput;
import org.apache.druid.indexing.common.TaskLockType;
import org.apache.druid.indexing.common.task.Tasks;
@@ -654,15 +655,15 @@ public class SupervisorManagerTest extends EasyMockSupport
);
final Object[] data = (Object[]) result.get("data");
- Assert.assertEquals(200, data.length);
- Assert.assertTrue(data[0] instanceof Map);
+ Assertions.assertEquals(200, data.length);
+ Assertions.assertInstanceOf(Map.class, data[0]);
final Map<?, ?> firstDataPoint = (Map<?, ?>) data[0];
- Assert.assertTrue(firstDataPoint.containsKey("lag"));
- Assert.assertTrue(firstDataPoint.containsKey("taskCount"));
+ Assertions.assertTrue(firstDataPoint.containsKey("lag"));
+ Assertions.assertTrue(firstDataPoint.containsKey("taskCount"));
for (Object dataPoint : data) {
- Assert.assertTrue(dataPoint instanceof Map);
+ Assertions.assertInstanceOf(Map.class, dataPoint);
final Number taskCount = (Number) ((Map<?, ?>)
dataPoint).get("taskCount");
- Assert.assertTrue(taskCount.intValue() >= 1 && taskCount.intValue() <=
10);
+ Assertions.assertTrue(taskCount.intValue() >= 1 && taskCount.intValue()
<= 10);
}
EasyMock.verify(supervisor);
}
@@ -684,8 +685,8 @@ public class SupervisorManagerTest extends EasyMockSupport
Pair.of(supervisor, new TestBackfillSupervisorSpec(supervisorId,
ingestionSpec))
);
- MatcherAssert.assertThat(
- Assert.assertThrows(
+ DruidExceptionMatcher.assertThat(
+ Assertions.assertThrows(
DruidException.class,
() -> manager.simulateAutoscaling(
supervisorId,
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
