Skip to content

Commit fe72cd7

Browse files
committed
Change test clusters configuration to support bcUpgradeTest explicitly
Added `.detachedVersion(System.getProperty("tests.bwc.refspec.main") != null)` to all the tests which apply 'elasticsearch.bc-upgrade-test' plugin to make them properly resolve distribution (previously configured by specifying `0.0.0` version).
1 parent 4494db3 commit fe72cd7

File tree

15 files changed

+24
-11
lines changed

15 files changed

+24
-11
lines changed

modules/ingest-geoip/qa/full-cluster-restart/src/javaRestTest/java/org/elasticsearch/ingest/geoip/FullClusterRestartIT.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -42,6 +42,7 @@ public class FullClusterRestartIT extends ParameterizedFullClusterRestartTestCas
4242
private static final ElasticsearchCluster cluster = ElasticsearchCluster.local()
4343
.distribution(DistributionType.DEFAULT)
4444
.version(Version.fromString(OLD_CLUSTER_VERSION))
45+
.detachedVersion(isOldClusterDetachedVersion())
4546
.nodes(2)
4647
.setting("ingest.geoip.downloader.endpoint", () -> fixture.getAddress(), s -> useFixture)
4748
.setting("xpack.security.enabled", "false")

qa/full-cluster-restart/src/javaRestTest/java/org/elasticsearch/upgrades/FullClusterRestartArchivedSettingsIT.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -46,6 +46,7 @@ public class FullClusterRestartArchivedSettingsIT extends ParameterizedFullClust
4646
private static ElasticsearchCluster cluster = ElasticsearchCluster.local()
4747
.distribution(DistributionType.DEFAULT)
4848
.version(Version.fromString(OLD_CLUSTER_VERSION))
49+
.detachedVersion(isOldClusterDetachedVersion())
4950
.nodes(2)
5051
.setting("path.repo", () -> repoDirectory.getRoot().getPath())
5152
.setting("xpack.security.enabled", "false")

qa/full-cluster-restart/src/javaRestTest/java/org/elasticsearch/upgrades/FullClusterRestartDownsampleIT.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -51,6 +51,7 @@ private static ElasticsearchCluster buildCluster() {
5151
var cluster = ElasticsearchCluster.local()
5252
.distribution(DistributionType.DEFAULT)
5353
.version(Version.fromString(OLD_CLUSTER_VERSION))
54+
.detachedVersion(isOldClusterDetachedVersion())
5455
.nodes(2)
5556
.setting("xpack.security.enabled", "false")
5657
.setting("indices.lifecycle.poll_interval", "5s")

qa/full-cluster-restart/src/javaRestTest/java/org/elasticsearch/upgrades/FullClusterRestartIT.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -110,6 +110,7 @@ private static ElasticsearchCluster buildCluster() {
110110
var cluster = ElasticsearchCluster.local()
111111
.distribution(DistributionType.DEFAULT)
112112
.version(Version.fromString(OLD_CLUSTER_VERSION))
113+
.detachedVersion(isOldClusterDetachedVersion())
113114
.nodes(2)
114115
.setting("path.repo", () -> repoDirectory.getRoot().getPath())
115116
.setting("xpack.security.enabled", "false")

qa/full-cluster-restart/src/javaRestTest/java/org/elasticsearch/upgrades/LogsIndexModeFullClusterRestartIT.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -40,6 +40,7 @@ private static ElasticsearchCluster buildCluster() {
4040
var cluster = ElasticsearchCluster.local()
4141
.distribution(DistributionType.DEFAULT)
4242
.version(Version.fromString(OLD_CLUSTER_VERSION))
43+
.detachedVersion(isOldClusterDetachedVersion())
4344
.module("constant-keyword")
4445
.module("data-streams")
4546
.module("mapper-extras")

qa/full-cluster-restart/src/javaRestTest/java/org/elasticsearch/upgrades/QueryBuilderBWCIT.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -74,6 +74,7 @@ public class QueryBuilderBWCIT extends ParameterizedFullClusterRestartTestCase {
7474
public static ElasticsearchCluster cluster = ElasticsearchCluster.local()
7575
.distribution(DistributionType.DEFAULT)
7676
.version(org.elasticsearch.test.cluster.util.Version.fromString(OLD_CLUSTER_VERSION))
77+
.detachedVersion(isOldClusterDetachedVersion())
7778
.nodes(2)
7879
.setting("xpack.security.enabled", "false")
7980
.apply(() -> clusterConfig)

qa/rolling-upgrade/src/javaRestTest/java/org/elasticsearch/upgrades/ParameterizedRollingUpgradeTestCase.java

Lines changed: 0 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -149,14 +149,6 @@ protected static String getOldClusterVersion() {
149149
return System.getProperty("tests.bwc.main.version", OLD_CLUSTER_VERSION);
150150
}
151151

152-
/**
153-
* Whether the old cluster version is not of the released versions, but a detached build.
154-
* In that case the Git ref has to be specified via {@code tests.bwc.refspec.main} system property.
155-
*/
156-
protected static boolean isOldClusterDetachedVersion() {
157-
return System.getProperty("tests.bwc.refspec.main") != null;
158-
}
159-
160152
protected static boolean isOldClusterVersion(String nodeVersion, String buildHash) {
161153
if (isOldClusterDetachedVersion()) {
162154
return System.getProperty("tests.bwc.refspec.main").equals(buildHash);

test/framework/src/main/java/org/elasticsearch/test/rest/ESRestTestCase.java

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -364,6 +364,14 @@ protected static boolean testFeatureServiceInitialized() {
364364
return testFeatureService != ALL_FEATURES;
365365
}
366366

367+
/**
368+
* Whether the old cluster version is not of the released versions, but a detached build.
369+
* In that case the Git ref has to be specified via {@code tests.bwc.refspec.main} system property.
370+
*/
371+
protected static boolean isOldClusterDetachedVersion() {
372+
return System.getProperty("tests.bwc.refspec.main") != null;
373+
}
374+
367375
@BeforeClass
368376
public static void initializeProjectIds() {
369377
// The active project-id is slightly longer, and has a fixed prefix so that it's easier to pick in error messages etc.

x-pack/plugin/ent-search/qa/full-cluster-restart/src/javaRestTest/java/org/elasticsearch/xpack/application/FullClusterRestartIT.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -42,6 +42,7 @@ public class FullClusterRestartIT extends ParameterizedFullClusterRestartTestCas
4242
public static final ElasticsearchCluster cluster = ElasticsearchCluster.local()
4343
.distribution(DistributionType.DEFAULT)
4444
.version(org.elasticsearch.test.cluster.util.Version.fromString(OLD_CLUSTER_VERSION))
45+
.detachedVersion(isOldClusterDetachedVersion())
4546
.nodes(2)
4647
.setting("xpack.security.enabled", "false")
4748
.setting("xpack.license.self_generated.type", "trial")

x-pack/plugin/esql/qa/server/mixed-cluster/src/javaRestTest/java/org/elasticsearch/xpack/esql/qa/mixed/Clusters.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -14,11 +14,12 @@
1414
public class Clusters {
1515
public static ElasticsearchCluster mixedVersionCluster() {
1616
Version oldVersion = Version.fromString(System.getProperty("tests.old_cluster_version"));
17+
boolean isDetachedVersion = System.getProperty("tests.bwc.refspec.main") != null;
1718
var cluster = ElasticsearchCluster.local()
1819
.distribution(DistributionType.DEFAULT)
19-
.withNode(node -> node.version(oldVersion))
20+
.withNode(node -> node.version(oldVersion).detachedVersion(isDetachedVersion))
2021
.withNode(node -> node.version(Version.CURRENT))
21-
.withNode(node -> node.version(oldVersion))
22+
.withNode(node -> node.version(oldVersion).detachedVersion(isDetachedVersion))
2223
.withNode(node -> node.version(Version.CURRENT))
2324
.setting("xpack.security.enabled", "false")
2425
.setting("xpack.license.self_generated.type", "trial");

0 commit comments

Comments
 (0)