Return after thread interruption

nielsbauman · nielsbauman · commit 7ec91668752d · 2025-09-05T10:52:19.000-03:00
diff --git a/modules/ingest-geoip/src/main/java/org/elasticsearch/ingest/geoip/EnterpriseGeoIpDownloader.java b/modules/ingest-geoip/src/main/java/org/elasticsearch/ingest/geoip/EnterpriseGeoIpDownloader.java
@@ -481,6 +481,7 @@ private void runOnState() {
             running.acquire();
         } catch (InterruptedException e) {
             logger.warn("Interrupted while waiting to run downloader on cluster state", e);
+            return;
         }
         // Get the last seen cluster state and process it.
         final ClusterState clusterState = queue.get();

Original file line number	Diff line number	Diff line change
`@@ -481,6 +481,7 @@ private void runOnState() {`
`481`	`481`	`running.acquire();`
`482`	`482`	`} catch (InterruptedException e) {`
`483`	`483`	`logger.warn("Interrupted while waiting to run downloader on cluster state", e);`
	`484`	`+ return;`
`484`	`485`	`}`
`485`	`486`	`// Get the last seen cluster state and process it.`
`486`	`487`	`final ClusterState clusterState = queue.get();`