File tree Expand file tree Collapse file tree 1 file changed +3
-2
lines changed
modules/ingest-geoip/src/main/java/org/elasticsearch/ingest/geoip Expand file tree Collapse file tree 1 file changed +3
-2
lines changed Original file line number Diff line number Diff line change @@ -297,6 +297,7 @@ void checkDatabases(ClusterState state) {
297297 void checkDatabases (ProjectState projectState ) {
298298 ProjectId projectId = projectState .projectId ();
299299 ProjectMetadata projectMetadata = projectState .metadata ();
300+ ClusterState clusterState = projectState .cluster ();
300301 PersistentTasksCustomMetadata persistentTasks = projectMetadata .custom (PersistentTasksCustomMetadata .TYPE );
301302 if (persistentTasks == null ) {
302303 logger .trace ("Not checking databases for project [{}] because persistent tasks are null" , projectId );
@@ -334,7 +335,7 @@ void checkDatabases(ProjectState projectState) {
334335 taskState .getDatabases ()
335336 .entrySet ()
336337 .stream ()
337- .filter (e -> e .getValue ().isNewEnough (projectState .settings ()))
338+ .filter (e -> e .getValue ().isNewEnough (projectState .cluster (). metadata (). settings ()))
338339 .map (entry -> Tuple .tuple (entry .getKey (), entry .getValue ()))
339340 .toList ()
340341 );
@@ -351,7 +352,7 @@ void checkDatabases(ProjectState projectState) {
351352 taskState .getDatabases ()
352353 .entrySet ()
353354 .stream ()
354- .filter (e -> e .getValue ().isNewEnough (projectState .settings ()))
355+ .filter (e -> e .getValue ().isNewEnough (projectState .cluster (). metadata (). settings ()))
355356 .map (entry -> Tuple .tuple (entry .getKey (), entry .getValue ()))
356357 .toList ()
357358 );
You can’t perform that action at this time.
0 commit comments