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 b2ca05f5020 test: fix flaky HistoricalCloningTest coordinator leader
switch (#20728)
b2ca05f5020 is described below
commit b2ca05f5020591cf5c7cda1eb75033c32636d3d1
Author: Mahesh Rijal <[email protected]>
AuthorDate: Mon Oct 26 19:34:21 2026 +0530
test: fix flaky HistoricalCloningTest coordinator leader switch (#20728)
---
.../apache/druid/testing/embedded/server/HistoricalCloningTest.java | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
diff --git
a/embedded-tests/src/test/java/org/apache/druid/testing/embedded/server/HistoricalCloningTest.java
b/embedded-tests/src/test/java/org/apache/druid/testing/embedded/server/HistoricalCloningTest.java
index 6c64443a4c3..a77d6fe7b4e 100644
---
a/embedded-tests/src/test/java/org/apache/druid/testing/embedded/server/HistoricalCloningTest.java
+++
b/embedded-tests/src/test/java/org/apache/druid/testing/embedded/server/HistoricalCloningTest.java
@@ -57,7 +57,6 @@ public class HistoricalCloningTest extends
EmbeddedClusterTestBase
.useLatchableEmitter()
.addServer(overlord)
.addServer(coordinator1)
- .addServer(coordinator2)
.addServer(new EmbeddedIndexer())
.addServer(historical1)
.addServer(new EmbeddedBroker())
@@ -98,6 +97,10 @@ public class HistoricalCloningTest extends
EmbeddedClusterTestBase
agg -> agg.hasSumAtLeast(10)
);
+ // Add coordinator2 only now so that coordinator1 is the leader for the
waits above
+ cluster.addServer(coordinator2);
+ coordinator2.start();
+
// Switch coordinator leader to force syncer to reset
coordinator1.stop();
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
