Add java system property to overseer queue size (#43) (#44)

cowpaths · Dec 1, 2022 · a2d0a89 · a2d0a89
1 parent 873b4c8
commit a2d0a89
Showing 1 changed file with 6 additions and 5 deletions.
diff --git a/solr/core/src/java/org/apache/solr/cloud/Overseer.java b/solr/core/src/java/org/apache/solr/cloud/Overseer.java
@@ -151,7 +151,8 @@ public class Overseer implements SolrCloseable {
   public static final int STATE_UPDATE_DELAY = ZkStateReader.STATE_UPDATE_DELAY;
   public static final int STATE_UPDATE_BATCH_SIZE =
       Integer.getInteger("solr.OverseerStateUpdateBatchSize", 10000);
-  public static final int STATE_UPDATE_MAX_QUEUE = 20000;
+  public static final int STATE_UPDATE_MAX_QUEUE =
+      Integer.getInteger("solr.OverseerStateUpdateMaxQueueSize", 20000);
 
   public static final int NUM_RESPONSES_TO_STORE = 10000;
   public static final String OVERSEER_ELECT = "/overseer_elect";
@@ -270,8 +271,8 @@ public void run() {
               byte[] data = fallbackQueue.peek();
               while (fallbackQueueSize > 0 && data != null) {
                 final ZkNodeProps message = ZkNodeProps.load(data);
-                if (log.isDebugEnabled()) {
-                  log.debug(
+                if (log.isInfoEnabled()) {
+                  log.info(
                       "processMessage: fallbackQueueSize: {}, message = {}",
                       fallbackQueue.getZkStats().getQueueLength(),
                       message);
@@ -335,8 +336,8 @@ public void run() {
               for (Pair<String, byte[]> head : queue) {
                 byte[] data = head.second();
                 final ZkNodeProps message = ZkNodeProps.load(data);
-                if (log.isDebugEnabled()) {
-                  log.debug(
+                if (log.isInfoEnabled()) {
+                  log.info(
                       "processMessage: queueSize: {}, message = {}",
                       stateUpdateQueue.getZkStats().getQueueLength(),
                       message);