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 2021/03/12 02:14:33 UTC
[lucene-solr] branch reference_impl updated: @1459 Put in the down
publish.
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 7db4993 @1459 Put in the down publish.
7db4993 is described below
commit 7db49937183de6b4d2071c910fbe5973a0d4fd0e
Author: markrmiller@gmail.com <ma...@gmail.com>
AuthorDate: Thu Mar 11 20:14:12 2021 -0600
@1459 Put in the down publish.
Took 10 minutes
---
solr/core/src/java/org/apache/solr/cloud/ZkController.java | 10 +++++-----
.../api/collections/CreateCollectionsIndexAndRestartTest.java | 2 +-
2 files changed, 6 insertions(+), 6 deletions(-)
diff --git a/solr/core/src/java/org/apache/solr/cloud/ZkController.java b/solr/core/src/java/org/apache/solr/cloud/ZkController.java
index a6b89cb..8d46016 100644
--- a/solr/core/src/java/org/apache/solr/cloud/ZkController.java
+++ b/solr/core/src/java/org/apache/solr/cloud/ZkController.java
@@ -153,11 +153,11 @@ public class ZkController implements Closeable, Runnable {
@Override
public void run() {
-// try {
-// publishNodeAs(getNodeName(), OverseerAction.DOWNNODE);
-// } catch (Exception e) {
-// log.warn("Problem publish node as DOWN", e);
-// }
+ try {
+ publishNodeAs(getNodeName(), OverseerAction.DOWNNODE);
+ } catch (Exception e) {
+ log.warn("Problem publish node as DOWN", e);
+ }
disconnect(true);
log.info("Continuing to Solr shutdown");
}
diff --git a/solr/core/src/test/org/apache/solr/cloud/api/collections/CreateCollectionsIndexAndRestartTest.java b/solr/core/src/test/org/apache/solr/cloud/api/collections/CreateCollectionsIndexAndRestartTest.java
index 3e70f81..e29c5fa 100644
--- a/solr/core/src/test/org/apache/solr/cloud/api/collections/CreateCollectionsIndexAndRestartTest.java
+++ b/solr/core/src/test/org/apache/solr/cloud/api/collections/CreateCollectionsIndexAndRestartTest.java
@@ -56,7 +56,7 @@ public class CreateCollectionsIndexAndRestartTest extends SolrCloudTestCase {
@Test
public void start() throws Exception {
- int collectionCnt = 2;
+ int collectionCnt = 30;
List<Future> futures = new ArrayList<>();
List<Future> indexFutures = new ArrayList<>();
for (int i = 0; i < collectionCnt; i ++) {