Skip to content

Commit 1330fb8

Browse files
authored
Update TransformSurvivesUpgradeIT.java
1 parent 0c07630 commit 1330fb8

File tree

1 file changed

+1
-15
lines changed

1 file changed

+1
-15
lines changed

x-pack/qa/rolling-upgrade/src/test/java/org/elasticsearch/upgrades/TransformSurvivesUpgradeIT.java

Lines changed: 1 addition & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -96,8 +96,7 @@ public void testTransformRollingUpgrade() throws Exception {
9696
if (Booleans.parseBoolean(System.getProperty("tests.first_round")) == false) {
9797
lastCheckpoint = 2;
9898
}
99-
verifyContinuousTransformHandlesData(lastCheckpoint);
100-
verifyUpgradeFailsIfMixedCluster();
99+
verifyContinuousTransformHandlesData(lastCheckpoint);
101100
}
102101
case UPGRADED -> {
103102
client().performRequest(waitForYellow);
@@ -233,19 +232,6 @@ private void verifyContinuousTransformHandlesData(long expectedLastCheckpoint) t
233232
});
234233
}
235234

236-
private void verifyUpgradeFailsIfMixedCluster() {
237-
// upgrade tests by design are also executed with the same version, this check must be skipped in this case, see gh#39102.
238-
if (isOriginalClusterCurrent()) {
239-
return;
240-
}
241-
var oldestVersion = Version.fromString(UPGRADE_FROM_VERSION);
242-
if (oldestVersion.onOrAfter(Version.V_9_3_0)) {
243-
final Request upgradeTransformRequest = new Request("POST", getTransformEndpoint() + "_upgrade");
244-
Exception ex = expectThrows(Exception.class, () -> client().performRequest(upgradeTransformRequest));
245-
assertThat(ex.getMessage(), containsString("Cannot upgrade transforms while cluster upgrade is in progress"));
246-
}
247-
}
248-
249235
private void verifyUpgrade() throws IOException {
250236
final Request upgradeTransformRequest = new Request("POST", getTransformEndpoint() + "_upgrade");
251237
Response response = client().performRequest(upgradeTransformRequest);

0 commit comments

Comments
 (0)