You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@lucene.apache.org by ma...@apache.org on 2020/10/05 17:21:08 UTC
[lucene-solr] 03/03: @943 Don't set max pool size here like this.
This is an automated email from the ASF dual-hosted git repository.
markrmiller pushed a commit to branch reference_impl_dev
in repository https://gitbox.apache.org/repos/asf/lucene-solr.git
commit c3d732050d54de7ce0947a98e519d3c914e6d717
Author: markrmiller@gmail.com <ma...@gmail.com>
AuthorDate: Mon Oct 5 11:33:24 2020 -0500
@943 Don't set max pool size here like this.
---
solr/core/src/java/org/apache/solr/update/UpdateShardHandler.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/solr/core/src/java/org/apache/solr/update/UpdateShardHandler.java b/solr/core/src/java/org/apache/solr/update/UpdateShardHandler.java
index cc48508..d9297cb 100644
--- a/solr/core/src/java/org/apache/solr/update/UpdateShardHandler.java
+++ b/solr/core/src/java/org/apache/solr/update/UpdateShardHandler.java
@@ -110,7 +110,7 @@ public class UpdateShardHandler implements SolrInfoBean {
.connectionTimeout(cfg.getDistributedConnectionTimeout())
.idleTimeout(cfg.getDistributedSocketTimeout());
}
- updateOnlyClient = updateOnlyClientBuilder.markInternalRequest().maxThreadPoolSize(ParWork.PROC_COUNT)
+ updateOnlyClient = updateOnlyClientBuilder.markInternalRequest()
.maxRequestsQueuedPerDestination(12000).strictEventOrdering(true).build();
updateOnlyClient.enableCloseLock();
// updateOnlyClient.addListenerFactory(updateHttpListenerFactory);
@@ -124,14 +124,14 @@ public class UpdateShardHandler implements SolrInfoBean {
recoveryOnlyClientBuilder.connectionTimeout(5000).idleTimeout(30000);
- recoveryOnlyClient = recoveryOnlyClientBuilder.markInternalRequest().maxThreadPoolSize(ParWork.PROC_COUNT).build();
+ recoveryOnlyClient = recoveryOnlyClientBuilder.markInternalRequest().build();
recoveryOnlyClient.enableCloseLock();
Http2SolrClient.Builder searchOnlyClientBuilder = new Http2SolrClient.Builder();
searchOnlyClientBuilder.connectionTimeout(5000).idleTimeout(60000);
- searchOnlyClient = recoveryOnlyClientBuilder.markInternalRequest().maxThreadPoolSize(ParWork.PROC_COUNT).build();
+ searchOnlyClient = recoveryOnlyClientBuilder.markInternalRequest().build();
searchOnlyClient.enableCloseLock();