Caused by: org.apache.solr.client.solrj.SolrServerException: 
java.lang.IllegalStateException: Connection pool shut down

org.apache.solr.client.solrj.SolrServerException: 
java.util.concurrent.RejectedExecutionException: Task 
org.apache.solr.common.util.ExecutorUtil$MDCAwareThreadPoolExecutor$1@5147c815 
rejected from 
org.apache.solr.common.util.ExecutorUtil$MDCAwareThreadPoolExecutor@35d2d02[Terminated,
 pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 0]
at 
org.apache.solr.client.solrj.impl.CloudSolrClient.requestWithRetryOnStaleState(CloudSolrClient.java:961)
at 
org.apache.solr.client.solrj.impl.CloudSolrClient.request(CloudSolrClient.java:805)
at org.apache.solr.client.solrj.SolrRequest.process(SolrRequest.java:135)
at org.apache.solr.client.solrj.SolrClient.add(SolrClient.java:107)
at org.apache.solr.client.solrj.SolrClient.add(SolrClient.java:72)
at 
search.solr.client.impl.SolJSolrCloudClient.updateIndices(SolJSolrCloudClient.scala:101)
at search.solr.client.user.SorlClientUI$IndexTask.call(SorlClientUI.scala:122)
at 
com.google.common.util.concurrent.TrustedListenableFutureTask$TrustedFutureInterruptibleTask.runInterruptibly(TrustedListenableFutureTask.java:108)
at 
com.google.common.util.concurrent.InterruptibleTask.run(InterruptibleTask.java:41)
at 
com.google.common.util.concurrent.TrustedListenableFutureTask.run(TrustedListenableFutureTask.java:77)
at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.util.concurrent.RejectedExecutionException: Task 
org.apache.solr.common.util.ExecutorUtil$MDCAwareThreadPoolExecutor$1@5147c815 
rejected from 
org.apache.solr.common.util.ExecutorUtil$MDCAwareThreadPoolExecutor@35d2d02[Terminated,
 pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 0]

I used Guawa asyn callback,In runnable task,I request zookeeper and 
CloudSolrServer for update my document
val executor = 
MoreExecutors.listeningDecorator(Executors.newFixedThreadPool(Runtime.getRuntime.availableProcessors()))
how can I deal with this

Thanks





soledede_w...@ehsy.com

Reply via email to