Skip to content

Commit 6f6b918

Browse files
authored
Update TransformSurvivesUpgradeIT.java
1 parent dab1efc commit 6f6b918

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
@@ -95,8 +95,7 @@ public void testTransformRollingUpgrade() throws Exception {
9595
if (Booleans.parseBoolean(System.getProperty("tests.first_round")) == false) {
9696
lastCheckpoint = 2;
9797
}
98-
verifyContinuousTransformHandlesData(lastCheckpoint);
99-
verifyUpgradeFailsIfMixedCluster();
98+
verifyContinuousTransformHandlesData(lastCheckpoint);
10099
}
101100
case UPGRADED -> {
102101
client().performRequest(waitForYellow);
@@ -232,19 +231,6 @@ private void verifyContinuousTransformHandlesData(long expectedLastCheckpoint) t
232231
});
233232
}
234233

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

0 commit comments

Comments
 (0)