You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@solr.apache.org by no...@apache.org on 2022/10/13 07:49:25 UTC

[solr] branch jira/solr-16640 updated: more logging 12

This is an automated email from the ASF dual-hosted git repository.

noble pushed a commit to branch jira/solr-16640
in repository https://gitbox.apache.org/repos/asf/solr.git


The following commit(s) were added to refs/heads/jira/solr-16640 by this push:
     new 0902081b394 more logging 12
0902081b394 is described below

commit 0902081b394c31421c8a6ba0d0d0e4f0db89a004
Author: Noble Paul <no...@gmail.com>
AuthorDate: Thu Oct 13 18:49:17 2022 +1100

    more logging 12
---
 solr/core/src/java/org/apache/solr/cloud/Overseer.java | 3 +++
 1 file changed, 3 insertions(+)

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 62b048f94f2..18b6877a539 100644
--- a/solr/core/src/java/org/apache/solr/cloud/Overseer.java
+++ b/solr/core/src/java/org/apache/solr/cloud/Overseer.java
@@ -353,6 +353,7 @@ public class Overseer implements SolrCloseable {
                 // are removed from workQueue but fail to be written to ZK
                 while (unprocessedMessages.size() > 0) {
                   clusterState = zkStateWriter.writePendingUpdates();
+                  log.info("CHECKPOINT9 , CS : {}", clusterState.hashCode());
                   Message m = unprocessedMessages.remove(0);
                   log.info("a_Message({})", m);
                   clusterState = m.run(clusterState, Overseer.this);
@@ -391,6 +392,8 @@ public class Overseer implements SolrCloseable {
             // we should force write all pending updates because the next iteration might sleep
             // until there are more items in the main queue
             clusterState = zkStateWriter.writePendingUpdates();
+            log.info("CHECKPOINT7: zkStateWriter.writePendingUpdates() CS: {}",clusterState.hashCode());
+
             // clean work queue
             stateUpdateQueue.remove(processedNodes);
             processedNodes.clear();