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();