Skip to content

Commit 6d425a4

Browse files
committed
Fix bug for atLeastOneGeoipProcessorByProject
1 parent b82df2f commit 6d425a4

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

modules/ingest-geoip/src/main/java/org/elasticsearch/ingest/geoip/GeoIpDownloaderTaskExecutor.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -199,7 +199,6 @@ protected GeoIpDownloader createTask(
199199
Map<String, String> headers
200200
) {
201201
ProjectId projectId = projectResolver.getProjectId();
202-
AtomicBoolean atLeastOneGeoipProcessor = atLeastOneGeoipProcessorByProject.get(projectId);
203202
return new GeoIpDownloader(
204203
client,
205204
httpClient,
@@ -214,7 +213,7 @@ protected GeoIpDownloader createTask(
214213
headers,
215214
() -> pollInterval,
216215
() -> eagerDownload,
217-
() -> atLeastOneGeoipProcessor != null && atLeastOneGeoipProcessor.get(),
216+
() -> atLeastOneGeoipProcessorByProject.get(projectId) != null && atLeastOneGeoipProcessorByProject.get(projectId).get(),
218217
projectId
219218
);
220219
}

0 commit comments

Comments
 (0)