This is an automated email from the ASF dual-hosted git repository.
FrankChen021 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 631f05de5d1 test: avoid racing supervisor history read (#20458)
631f05de5d1 is described below
commit 631f05de5d1d05edfbbab3adc8dbbb99745678ee
Author: Edmond Abraham <[email protected]>
AuthorDate: Thu Oct 1 08:47:14 2026 -0400
test: avoid racing supervisor history read (#20458)
---
.../testing/embedded/server/KillSupervisorsCustomDutyTest.java | 6 ------
1 file changed, 6 deletions(-)
diff --git
a/embedded-tests/src/test/java/org/apache/druid/testing/embedded/server/KillSupervisorsCustomDutyTest.java
b/embedded-tests/src/test/java/org/apache/druid/testing/embedded/server/KillSupervisorsCustomDutyTest.java
index 3bcd422e3f7..33df37898a6 100644
---
a/embedded-tests/src/test/java/org/apache/druid/testing/embedded/server/KillSupervisorsCustomDutyTest.java
+++
b/embedded-tests/src/test/java/org/apache/druid/testing/embedded/server/KillSupervisorsCustomDutyTest.java
@@ -23,7 +23,6 @@ import com.fasterxml.jackson.core.type.TypeReference;
import io.netty.handler.codec.http.HttpMethod;
import org.apache.druid.error.ExceptionMatcher;
import org.apache.druid.indexing.compact.CompactionSupervisorSpec;
-import org.apache.druid.indexing.overlord.supervisor.NoopSupervisorSpec;
import org.apache.druid.indexing.overlord.supervisor.SupervisorSpec;
import org.apache.druid.indexing.overlord.supervisor.VersionedSupervisorSpec;
import org.apache.druid.java.util.common.StringUtils;
@@ -83,11 +82,6 @@ public class KillSupervisorsCustomDutyTest extends
EmbeddedClusterTestBase
// Terminate the supervisor
cluster.callApi().onLeaderOverlord(o ->
o.terminateSupervisor(supervisor.getId()));
- // Verify that the history now has 2 entries and the latest entry is a
tombstone
- final List<VersionedSupervisorSpec> historyAfterTermination =
getSupervisorHistory(supervisor.getId());
- Assertions.assertEquals(2, historyAfterTermination.size());
- Assertions.assertInstanceOf(NoopSupervisorSpec.class,
historyAfterTermination.get(0).getSpec());
-
// Wait until both entries have been cleaned up.
coordinator.latchableEmitter().waitForEventAggregate(
event -> event.hasMetricName("metadata/kill/supervisor/count"),
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
