You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@lucene.apache.org by da...@apache.org on 2017/12/18 07:39:50 UTC
[2/2] lucene-solr:jira/solr-11702: SOLR-11711: Overseer can never
process some last messages
SOLR-11711: Overseer can never process some last messages
Project: http://git-wip-us.apache.org/repos/asf/lucene-solr/repo
Commit: http://git-wip-us.apache.org/repos/asf/lucene-solr/commit/83081740
Tree: http://git-wip-us.apache.org/repos/asf/lucene-solr/tree/83081740
Diff: http://git-wip-us.apache.org/repos/asf/lucene-solr/diff/83081740
Branch: refs/heads/jira/solr-11702
Commit: 830817405ee9c20e8dbe76f9df2cfd7f1f7c3350
Parents: 162250e
Author: Cao Manh Dat <da...@apache.org>
Authored: Mon Dec 18 14:39:33 2017 +0700
Committer: Cao Manh Dat <da...@apache.org>
Committed: Mon Dec 18 14:39:33 2017 +0700
----------------------------------------------------------------------
solr/core/src/java/org/apache/solr/cloud/Overseer.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/lucene-solr/blob/83081740/solr/core/src/java/org/apache/solr/cloud/Overseer.java
----------------------------------------------------------------------
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 3b65d6f..813b1ed 100644
--- a/solr/core/src/java/org/apache/solr/cloud/Overseer.java
+++ b/solr/core/src/java/org/apache/solr/cloud/Overseer.java
@@ -200,7 +200,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, 2000L, (x) -> true));
} catch (KeeperException.SessionExpiredException e) {
log.warn("Solr cannot talk to ZK, exiting Overseer main queue loop", e);
return;