You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@druid.apache.org by fr...@apache.org on 2026/10/01 12:47:20 UTC
(druid) branch master updated: test: avoid racing supervisor history read (#20458)
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 <54...@users.noreply.github.com>
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: commits-unsubscribe@druid.apache.org
For additional commands, e-mail: commits-help@druid.apache.org