comment

samxbr · samxbr · commit 96654ddcc150 · 2025-06-21T01:06:22.000+08:00
diff --git a/modules/ingest-geoip/src/main/java/org/elasticsearch/ingest/geoip/GeoIpDownloaderTaskExecutor.java b/modules/ingest-geoip/src/main/java/org/elasticsearch/ingest/geoip/GeoIpDownloaderTaskExecutor.java
@@ -253,7 +253,7 @@ public void clusterChanged(ClusterChangedEvent event) {
             }
 
             if (hasIngestPipelineChanges || hasIndicesChanges) {
-                boolean atLeastOneGeoipProcessor = atLeastOneGeoipProcessorByProject.computeIfAbsent(projectId, k -> false);
+                boolean atLeastOneGeoipProcessor = atLeastOneGeoipProcessorByProject.getOrDefault(projectId, false);
                 boolean newAtLeastOneGeoipProcessor = hasAtLeastOneGeoipProcessor(projectMetadata);
                 // update if necessary
                 if (newAtLeastOneGeoipProcessor != atLeastOneGeoipProcessor) {

Original file line number	Diff line number	Diff line change
`@@ -253,7 +253,7 @@ public void clusterChanged(ClusterChangedEvent event) {`
`253`	`253`	`}`
`254`	`254`
`255`	`255`	`if (hasIngestPipelineChanges \|\| hasIndicesChanges) {`
`256`		`- boolean atLeastOneGeoipProcessor = atLeastOneGeoipProcessorByProject.computeIfAbsent(projectId, k -> false);`
	`256`	`+ boolean atLeastOneGeoipProcessor = atLeastOneGeoipProcessorByProject.getOrDefault(projectId, false);`
`257`	`257`	`boolean newAtLeastOneGeoipProcessor = hasAtLeastOneGeoipProcessor(projectMetadata);`
`258`	`258`	`// update if necessary`
`259`	`259`	`if (newAtLeastOneGeoipProcessor != atLeastOneGeoipProcessor) {`