diff --git a/solr/CHANGES.txt b/solr/CHANGES.txt index 221d6adb1c1..3da194beb6c 100644 --- a/solr/CHANGES.txt +++ b/solr/CHANGES.txt @@ -86,6 +86,8 @@ Bug Fixes * SOLR-11555: If the query terms reduce to nothing, filter(clause) produces an NPE whereas fq=clause does not (Erick Erickson) +* SOLR-11771: Overseer can never process some last messages (Cao Manh Dat) + Optimizations ---------------------- diff --git a/solr/core/src/java/org/apache/solr/cloud/Overseer.java b/solr/core/src/java/org/apache/solr/cloud/Overseer.java index 3b9dd28f3b6..ee5fb183db7 100644 --- a/solr/core/src/java/org/apache/solr/cloud/Overseer.java +++ b/solr/core/src/java/org/apache/solr/cloud/Overseer.java @@ -201,7 +201,7 @@ public class Overseer implements SolrCloseable { LinkedList> queue = null; try { // We do not need to filter any nodes here cause all processed nodes are removed once we flush clusterstate - queue = new LinkedList<>(stateUpdateQueue.peekElements(1000, Long.MAX_VALUE, (x) -> true)); + queue = new LinkedList<>(stateUpdateQueue.peekElements(1000, 3000L, (x) -> true)); } catch (KeeperException.SessionExpiredException e) { log.warn("Solr cannot talk to ZK, exiting Overseer main queue loop", e); return;