Skip to content

Commit 52a9860

Browse files
committed
Merge branch 'main' into 2025/03/18/repository-s3-sdk-v2
2 parents fdf7b50 + d9e3b20 commit 52a9860

File tree

202 files changed

+6205
-2779
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

202 files changed

+6205
-2779
lines changed

build-tools-internal/src/main/java/org/elasticsearch/gradle/internal/DockerBase.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@
1414
*/
1515
public enum DockerBase {
1616
// "latest" here is intentional, since the image name specifies "9"
17-
DEFAULT("docker.elastic.co/ubi9/ubi-minimal:latest", "", "microdnf"),
17+
DEFAULT("redhat/ubi9-minimal:latest", "", "microdnf"),
1818

1919
// The Iron Bank base image is UBI (albeit hardened), but we are required to parameterize the Docker build
2020
IRON_BANK("${BASE_REGISTRY}/${BASE_IMAGE}:${BASE_TAG}", "-ironbank", "yum"),

docs/changelog/123074.yaml

+5
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,5 @@
1+
pr: 123074
2+
summary: Adding ES|QL Reranker command in snapshot builds
3+
area: Ranking
4+
type: feature
5+
issues: []

docs/changelog/125060.yaml

-16
This file was deleted.

docs/changelog/126008.yaml

+6
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,6 @@
1+
pr: 126008
2+
summary: Accumulate compute() calls and iterations between convergences
3+
area: Allocation
4+
type: enhancement
5+
issues:
6+
- 100850

docs/changelog/126286.yaml

+6
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,6 @@
1+
pr: 126286
2+
summary: Revert "Allow partial results by default in ES|QL"
3+
area: ES|QL
4+
type: bug
5+
issues:
6+
- 126275

docs/release-notes/breaking-changes.md

-5
Original file line numberDiff line numberDiff line change
@@ -14,11 +14,6 @@ To learn how to upgrade, check out <uprade docs>.
1414

1515
% ## Next version [elasticsearch-nextversion-breaking-changes]
1616

17-
## 9.1.0 [elasticsearch-910-breaking-changes]
18-
19-
ES|QL
20-
: * Allow partial results by default in ES|QL [#125060](https://github.com/elastic/elasticsearch/pull/125060)
21-
2217
## 9.0.0 [elasticsearch-900-breaking-changes]
2318

2419
Allocation
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,3 @@
1+
grant {
2+
permission java.lang.RuntimePermission "accessDeclaredMembers";
3+
};
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,3 @@
1+
grant {
2+
permission java.lang.RuntimePermission "accessDeclaredMembers";
3+
};

modules/repository-s3/src/javaRestTest/java/org/elasticsearch/repositories/s3/RepositoryS3BasicCredentialsRestIT.java

+2-1
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,7 @@
2020
import org.junit.rules.RuleChain;
2121
import org.junit.rules.TestRule;
2222

23+
import static fixture.aws.AwsCredentialsUtils.ANY_REGION;
2324
import static fixture.aws.AwsCredentialsUtils.fixedAccessKey;
2425

2526
@ThreadLeakFilters(filters = { TestContainersThreadFilter.class })
@@ -33,7 +34,7 @@ public class RepositoryS3BasicCredentialsRestIT extends AbstractRepositoryS3Rest
3334
private static final String SECRET_KEY = PREFIX + "secret-key";
3435
private static final String CLIENT = "basic_credentials_client";
3536

36-
private static final S3HttpFixture s3Fixture = new S3HttpFixture(true, BUCKET, BASE_PATH, fixedAccessKey(ACCESS_KEY, "*", "s3"));
37+
private static final S3HttpFixture s3Fixture = new S3HttpFixture(true, BUCKET, BASE_PATH, fixedAccessKey(ACCESS_KEY, ANY_REGION, "s3"));
3738

3839
public static ElasticsearchCluster cluster = ElasticsearchCluster.local()
3940
.module("repository-s3")

modules/repository-s3/src/javaRestTest/java/org/elasticsearch/repositories/s3/RepositoryS3RestReloadCredentialsIT.java

+2-1
Original file line numberDiff line numberDiff line change
@@ -25,6 +25,7 @@
2525

2626
import java.io.IOException;
2727

28+
import static fixture.aws.AwsCredentialsUtils.ANY_REGION;
2829
import static fixture.aws.AwsCredentialsUtils.mutableAccessKey;
2930
import static org.hamcrest.CoreMatchers.containsString;
3031
import static org.hamcrest.Matchers.allOf;
@@ -42,7 +43,7 @@ public class RepositoryS3RestReloadCredentialsIT extends ESRestTestCase {
4243
true,
4344
BUCKET,
4445
BASE_PATH,
45-
mutableAccessKey(() -> repositoryAccessKey, "*", "s3")
46+
mutableAccessKey(() -> repositoryAccessKey, ANY_REGION, "s3")
4647
);
4748

4849
private static final MutableSettingsProvider keystoreSettings = new MutableSettingsProvider();

modules/repository-s3/src/javaRestTest/java/org/elasticsearch/repositories/s3/RepositoryS3SessionCredentialsRestIT.java

+2-1
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,7 @@
2020
import org.junit.rules.RuleChain;
2121
import org.junit.rules.TestRule;
2222

23+
import static fixture.aws.AwsCredentialsUtils.ANY_REGION;
2324
import static fixture.aws.AwsCredentialsUtils.fixedAccessKeyAndToken;
2425

2526
@ThreadLeakFilters(filters = { TestContainersThreadFilter.class })
@@ -38,7 +39,7 @@ public class RepositoryS3SessionCredentialsRestIT extends AbstractRepositoryS3Re
3839
true,
3940
BUCKET,
4041
BASE_PATH,
41-
fixedAccessKeyAndToken(ACCESS_KEY, SESSION_TOKEN, "*", "s3")
42+
fixedAccessKeyAndToken(ACCESS_KEY, SESSION_TOKEN, ANY_REGION, "s3")
4243
);
4344

4445
public static ElasticsearchCluster cluster = ElasticsearchCluster.local()

modules/repository-s3/src/yamlRestTest/java/org/elasticsearch/repositories/s3/RepositoryS3ClientYamlTestSuiteIT.java

+2-1
Original file line numberDiff line numberDiff line change
@@ -23,6 +23,7 @@
2323
import org.junit.rules.RuleChain;
2424
import org.junit.rules.TestRule;
2525

26+
import static fixture.aws.AwsCredentialsUtils.ANY_REGION;
2627
import static fixture.aws.AwsCredentialsUtils.fixedAccessKey;
2728

2829
@ThreadLeakFilters(filters = { TestContainersThreadFilter.class })
@@ -36,7 +37,7 @@ public class RepositoryS3ClientYamlTestSuiteIT extends AbstractRepositoryS3Clien
3637
true,
3738
"bucket",
3839
"base_path_integration_tests",
39-
fixedAccessKey(ACCESS_KEY, "*", "s3")
40+
fixedAccessKey(ACCESS_KEY, ANY_REGION, "s3")
4041
);
4142

4243
public static ElasticsearchCluster cluster = ElasticsearchCluster.local()

muted-tests.yml

+12-3
Original file line numberDiff line numberDiff line change
@@ -345,9 +345,6 @@ tests:
345345
- class: org.elasticsearch.xpack.test.rest.XPackRestIT
346346
method: test {p0=transform/transforms_stats/Test get transform stats with timeout}
347347
issue: https://github.com/elastic/elasticsearch/issues/125975
348-
- class: org.elasticsearch.search.SearchServiceSingleNodeTests
349-
method: testSlicingBehaviourForParallelCollection
350-
issue: https://github.com/elastic/elasticsearch/issues/125899
351348
- class: org.elasticsearch.packaging.test.DockerTests
352349
method: test021InstallPlugin
353350
issue: https://github.com/elastic/elasticsearch/issues/116147
@@ -369,6 +366,9 @@ tests:
369366
- class: org.elasticsearch.snapshots.SharedClusterSnapshotRestoreIT
370367
method: testDeletionOfFailingToRecoverIndexShouldStopRestore
371368
issue: https://github.com/elastic/elasticsearch/issues/126204
369+
- class: org.elasticsearch.xpack.esql.inference.RerankOperatorTests
370+
method: testSimpleCircuitBreaking
371+
issue: https://github.com/elastic/elasticsearch/issues/124337
372372
- class: org.elasticsearch.index.engine.ThreadPoolMergeSchedulerTests
373373
method: testSchedulerCloseWaitsForRunningMerge
374374
issue: https://github.com/elastic/elasticsearch/issues/125236
@@ -393,6 +393,15 @@ tests:
393393
- class: org.elasticsearch.xpack.test.rest.XPackRestIT
394394
method: test {p0=transform/transforms_stats/Test get transform stats}
395395
issue: https://github.com/elastic/elasticsearch/issues/126270
396+
- class: org.elasticsearch.xpack.test.rest.XPackRestIT
397+
method: test {p0=ml/start_data_frame_analytics/Test start classification analysis when the dependent variable cardinality is too low}
398+
issue: https://github.com/elastic/elasticsearch/issues/126299
399+
- class: org.elasticsearch.xpack.esql.qa.multi_node.EsqlSpecIT
400+
method: test {rerank.Reranker using multiple fields SYNC}
401+
issue: https://github.com/elastic/elasticsearch/issues/126320
402+
- class: org.elasticsearch.xpack.esql.qa.multi_node.EsqlSpecIT
403+
method: test {rerank.Reranker before a limit SYNC}
404+
issue: https://github.com/elastic/elasticsearch/issues/126322
396405

397406
# Examples:
398407
#

plugins/discovery-ec2/src/javaRestTest/java/org/elasticsearch/discovery/ec2/DiscoveryEc2EnvironmentVariableCredentialsIT.java

+5-3
Original file line numberDiff line numberDiff line change
@@ -9,6 +9,7 @@
99

1010
package org.elasticsearch.discovery.ec2;
1111

12+
import fixture.aws.DynamicRegionSupplier;
1213
import fixture.aws.ec2.AwsEc2HttpFixture;
1314

1415
import org.elasticsearch.discovery.DiscoveryModule;
@@ -19,17 +20,18 @@
1920
import org.junit.rules.TestRule;
2021

2122
import java.util.List;
23+
import java.util.function.Supplier;
2224

2325
import static fixture.aws.AwsCredentialsUtils.fixedAccessKey;
2426

2527
public class DiscoveryEc2EnvironmentVariableCredentialsIT extends DiscoveryEc2ClusterFormationTestCase {
2628

2729
private static final String PREFIX = getIdentifierPrefix("DiscoveryEc2EnvironmentVariableCredentialsIT");
28-
private static final String REGION = PREFIX + "-region";
2930
private static final String ACCESS_KEY = PREFIX + "-access-key";
3031

32+
private static final Supplier<String> regionSupplier = new DynamicRegionSupplier();
3133
private static final AwsEc2HttpFixture ec2ApiFixture = new AwsEc2HttpFixture(
32-
fixedAccessKey(ACCESS_KEY, REGION, "ec2"),
34+
fixedAccessKey(ACCESS_KEY, regionSupplier, "ec2"),
3335
DiscoveryEc2EnvironmentVariableCredentialsIT::getAvailableTransportEndpoints
3436
);
3537

@@ -39,7 +41,7 @@ public class DiscoveryEc2EnvironmentVariableCredentialsIT extends DiscoveryEc2Cl
3941
.setting(DiscoveryModule.DISCOVERY_SEED_PROVIDERS_SETTING.getKey(), Ec2DiscoveryPlugin.EC2_SEED_HOSTS_PROVIDER_NAME)
4042
.setting("logger." + AwsEc2SeedHostsProvider.class.getCanonicalName(), "DEBUG")
4143
.setting(Ec2ClientSettings.ENDPOINT_SETTING.getKey(), ec2ApiFixture::getAddress)
42-
.environment("AWS_REGION", REGION)
44+
.environment("AWS_REGION", regionSupplier)
4345
.environment("AWS_ACCESS_KEY_ID", ACCESS_KEY)
4446
.environment("AWS_SECRET_ACCESS_KEY", ESTestCase::randomSecretKey)
4547
.build();

plugins/discovery-ec2/src/javaRestTest/java/org/elasticsearch/discovery/ec2/DiscoveryEc2KeystoreCredentialsIT.java

+5-3
Original file line numberDiff line numberDiff line change
@@ -9,6 +9,7 @@
99

1010
package org.elasticsearch.discovery.ec2;
1111

12+
import fixture.aws.DynamicRegionSupplier;
1213
import fixture.aws.ec2.AwsEc2HttpFixture;
1314

1415
import org.elasticsearch.discovery.DiscoveryModule;
@@ -19,17 +20,18 @@
1920
import org.junit.rules.TestRule;
2021

2122
import java.util.List;
23+
import java.util.function.Supplier;
2224

2325
import static fixture.aws.AwsCredentialsUtils.fixedAccessKey;
2426

2527
public class DiscoveryEc2KeystoreCredentialsIT extends DiscoveryEc2ClusterFormationTestCase {
2628

2729
private static final String PREFIX = getIdentifierPrefix("DiscoveryEc2KeystoreCredentialsIT");
28-
private static final String REGION = PREFIX + "-region";
2930
private static final String ACCESS_KEY = PREFIX + "-access-key";
3031

32+
private static final Supplier<String> regionSupplier = new DynamicRegionSupplier();
3133
private static final AwsEc2HttpFixture ec2ApiFixture = new AwsEc2HttpFixture(
32-
fixedAccessKey(ACCESS_KEY, REGION, "ec2"),
34+
fixedAccessKey(ACCESS_KEY, regionSupplier, "ec2"),
3335
DiscoveryEc2KeystoreCredentialsIT::getAvailableTransportEndpoints
3436
);
3537

@@ -39,7 +41,7 @@ public class DiscoveryEc2KeystoreCredentialsIT extends DiscoveryEc2ClusterFormat
3941
.setting(DiscoveryModule.DISCOVERY_SEED_PROVIDERS_SETTING.getKey(), Ec2DiscoveryPlugin.EC2_SEED_HOSTS_PROVIDER_NAME)
4042
.setting("logger." + AwsEc2SeedHostsProvider.class.getCanonicalName(), "DEBUG")
4143
.setting(Ec2ClientSettings.ENDPOINT_SETTING.getKey(), ec2ApiFixture::getAddress)
42-
.environment("AWS_REGION", REGION)
44+
.environment("AWS_REGION", regionSupplier)
4345
.keystore("discovery.ec2.access_key", ACCESS_KEY)
4446
.keystore("discovery.ec2.secret_key", ESTestCase::randomSecretKey)
4547
.build();

plugins/discovery-ec2/src/javaRestTest/java/org/elasticsearch/discovery/ec2/DiscoveryEc2KeystoreSessionCredentialsIT.java

+5-3
Original file line numberDiff line numberDiff line change
@@ -9,6 +9,7 @@
99

1010
package org.elasticsearch.discovery.ec2;
1111

12+
import fixture.aws.DynamicRegionSupplier;
1213
import fixture.aws.ec2.AwsEc2HttpFixture;
1314

1415
import org.elasticsearch.discovery.DiscoveryModule;
@@ -19,18 +20,19 @@
1920
import org.junit.rules.TestRule;
2021

2122
import java.util.List;
23+
import java.util.function.Supplier;
2224

2325
import static fixture.aws.AwsCredentialsUtils.fixedAccessKeyAndToken;
2426

2527
public class DiscoveryEc2KeystoreSessionCredentialsIT extends DiscoveryEc2ClusterFormationTestCase {
2628

2729
private static final String PREFIX = getIdentifierPrefix("DiscoveryEc2KeystoreSessionCredentialsIT");
28-
private static final String REGION = PREFIX + "-region";
2930
private static final String ACCESS_KEY = PREFIX + "-access-key";
3031
private static final String SESSION_TOKEN = PREFIX + "-session-token";
3132

33+
private static final Supplier<String> regionSupplier = new DynamicRegionSupplier();
3234
private static final AwsEc2HttpFixture ec2ApiFixture = new AwsEc2HttpFixture(
33-
fixedAccessKeyAndToken(ACCESS_KEY, SESSION_TOKEN, REGION, "ec2"),
35+
fixedAccessKeyAndToken(ACCESS_KEY, SESSION_TOKEN, regionSupplier, "ec2"),
3436
DiscoveryEc2KeystoreSessionCredentialsIT::getAvailableTransportEndpoints
3537
);
3638

@@ -40,7 +42,7 @@ public class DiscoveryEc2KeystoreSessionCredentialsIT extends DiscoveryEc2Cluste
4042
.setting(DiscoveryModule.DISCOVERY_SEED_PROVIDERS_SETTING.getKey(), Ec2DiscoveryPlugin.EC2_SEED_HOSTS_PROVIDER_NAME)
4143
.setting("logger." + AwsEc2SeedHostsProvider.class.getCanonicalName(), "DEBUG")
4244
.setting(Ec2ClientSettings.ENDPOINT_SETTING.getKey(), ec2ApiFixture::getAddress)
43-
.environment("AWS_REGION", REGION)
45+
.environment("AWS_REGION", regionSupplier)
4446
.keystore("discovery.ec2.access_key", ACCESS_KEY)
4547
.keystore("discovery.ec2.secret_key", ESTestCase::randomSecretKey)
4648
.keystore("discovery.ec2.session_token", SESSION_TOKEN)

plugins/discovery-ec2/src/javaRestTest/java/org/elasticsearch/discovery/ec2/DiscoveryEc2SystemPropertyCredentialsIT.java

+5-3
Original file line numberDiff line numberDiff line change
@@ -9,6 +9,7 @@
99

1010
package org.elasticsearch.discovery.ec2;
1111

12+
import fixture.aws.DynamicRegionSupplier;
1213
import fixture.aws.ec2.AwsEc2HttpFixture;
1314

1415
import org.elasticsearch.discovery.DiscoveryModule;
@@ -19,17 +20,18 @@
1920
import org.junit.rules.TestRule;
2021

2122
import java.util.List;
23+
import java.util.function.Supplier;
2224

2325
import static fixture.aws.AwsCredentialsUtils.fixedAccessKey;
2426

2527
public class DiscoveryEc2SystemPropertyCredentialsIT extends DiscoveryEc2ClusterFormationTestCase {
2628

2729
private static final String PREFIX = getIdentifierPrefix("DiscoveryEc2SystemPropertyCredentialsIT");
28-
private static final String REGION = PREFIX + "-region";
2930
private static final String ACCESS_KEY = PREFIX + "-access-key";
3031

32+
private static final Supplier<String> regionSupplier = new DynamicRegionSupplier();
3133
private static final AwsEc2HttpFixture ec2ApiFixture = new AwsEc2HttpFixture(
32-
fixedAccessKey(ACCESS_KEY, REGION, "ec2"),
34+
fixedAccessKey(ACCESS_KEY, regionSupplier, "ec2"),
3335
DiscoveryEc2SystemPropertyCredentialsIT::getAvailableTransportEndpoints
3436
);
3537

@@ -39,7 +41,7 @@ public class DiscoveryEc2SystemPropertyCredentialsIT extends DiscoveryEc2Cluster
3941
.setting(DiscoveryModule.DISCOVERY_SEED_PROVIDERS_SETTING.getKey(), Ec2DiscoveryPlugin.EC2_SEED_HOSTS_PROVIDER_NAME)
4042
.setting("logger." + AwsEc2SeedHostsProvider.class.getCanonicalName(), "DEBUG")
4143
.setting(Ec2ClientSettings.ENDPOINT_SETTING.getKey(), ec2ApiFixture::getAddress)
42-
.environment("AWS_REGION", REGION)
44+
.environment("AWS_REGION", regionSupplier)
4345
.systemProperty("aws.accessKeyId", ACCESS_KEY)
4446
.systemProperty("aws.secretAccessKey", ESTestCase::randomSecretKey)
4547
.build();

0 commit comments

Comments
 (0)