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/07/26 16:59:09 UTC
[lucene-solr] branch reference_impl updated: @349 Propagate out
AlreadyClosed.
This is an automated email from the ASF dual-hosted git repository.
markrmiller pushed a commit to branch reference_impl
in repository https://gitbox.apache.org/repos/asf/lucene-solr.git
The following commit(s) were added to refs/heads/reference_impl by this push:
new 4e5f003 @349 Propagate out AlreadyClosed.
4e5f003 is described below
commit 4e5f0030ca90b9f564e452707946aed4f19315d6
Author: markrmiller@gmail.com <ma...@gmail.com>
AuthorDate: Sun Jul 26 11:58:51 2020 -0500
@349 Propagate out AlreadyClosed.
---
solr/core/src/java/org/apache/solr/cloud/overseer/ZkStateWriter.java | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
diff --git a/solr/core/src/java/org/apache/solr/cloud/overseer/ZkStateWriter.java b/solr/core/src/java/org/apache/solr/cloud/overseer/ZkStateWriter.java
index 7c39db3..ef558b4 100644
--- a/solr/core/src/java/org/apache/solr/cloud/overseer/ZkStateWriter.java
+++ b/solr/core/src/java/org/apache/solr/cloud/overseer/ZkStateWriter.java
@@ -123,6 +123,9 @@ public class ZkStateWriter {
continue;
// log.info("BadVersion");
// throw new AlreadyClosedException();
+ } catch (InterruptedException | AlreadyClosedException e) {
+ ParWork.propegateInterrupt(e);
+ throw e;
} catch (Exception e) {
log.error("Ran into unexpected exception trying to write new cluster state", e);
throw new SolrException(SolrException.ErrorCode.SERVER_ERROR, e);
@@ -288,7 +291,7 @@ public class ZkStateWriter {
}
}
- } catch (InterruptedException e) {
+ } catch (InterruptedException | AlreadyClosedException e) {
ParWork.propegateInterrupt(e);
throw e;
} catch (Exception e) {