SOLR-11771: Overseer can never process some last messages

This commit is contained in:
Cao Manh Dat 2018-01-06 09:05:14 +07:00
parent 925733d1ef
commit b8b00786f3
2 changed files with 3 additions and 1 deletions

View File

@ -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
----------------------

View File

@ -201,7 +201,7 @@ public class Overseer implements SolrCloseable {
LinkedList<Pair<String, byte[]>> 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;