Skip to content

Commit 9bc5d09

Browse files
committed
nodeSettings
1 parent 0f1bdd5 commit 9bc5d09

File tree

1 file changed

+5
-5
lines changed
  • modules/repository-s3/src/main/java/org/elasticsearch/repositories/s3

1 file changed

+5
-5
lines changed

modules/repository-s3/src/main/java/org/elasticsearch/repositories/s3/S3Service.java

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -137,21 +137,21 @@ class S3Service extends AbstractLifecycleComponent {
137137
ResourceWatcherService resourceWatcherService,
138138
Supplier<Region> defaultRegionSupplier
139139
) {
140-
final Settings settings = clusterService.getSettings();
140+
final Settings nodeSettings = clusterService.getSettings();
141141
webIdentityTokenCredentialsProvider = new CustomWebIdentityTokenCredentialsProvider(
142142
environment,
143143
System::getenv,
144144
System::getProperty,
145145
Clock.systemUTC(),
146146
resourceWatcherService
147147
);
148-
compareAndExchangeTimeToLive = REPOSITORY_S3_CAS_TTL_SETTING.get(settings);
149-
compareAndExchangeAntiContentionDelay = REPOSITORY_S3_CAS_ANTI_CONTENTION_DELAY_SETTING.get(settings);
150-
isStateless = DiscoveryNode.isStateless(settings);
148+
compareAndExchangeTimeToLive = REPOSITORY_S3_CAS_TTL_SETTING.get(nodeSettings);
149+
compareAndExchangeAntiContentionDelay = REPOSITORY_S3_CAS_ANTI_CONTENTION_DELAY_SETTING.get(nodeSettings);
150+
isStateless = DiscoveryNode.isStateless(nodeSettings);
151151
defaultRegionSetter = new RunOnce(() -> defaultRegion = defaultRegionSupplier.get());
152152
if (projectResolver.supportsMultipleProjects()) {
153153
s3PerProjectClientManager = new S3PerProjectClientManager(
154-
settings,
154+
nodeSettings,
155155
this::buildClientReference,
156156
clusterService.threadPool().generic()
157157
);

0 commit comments

Comments
 (0)