From 526ad66f0027646fe0ca0bac60b3b3c2cbe1be9b Mon Sep 17 00:00:00 2001
From: Nick Ginther <104029658+nginthfs@users.noreply.github.com>
Date: Thu, 1 Dec 2022 10:28:53 -0600
Subject: [PATCH] Add java system property to overseer queue size (#43) (#44)

---
 .../core/src/java/org/apache/solr/cloud/Overseer.java | 11 ++++++-----
 1 file changed, 6 insertions(+), 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
index 28a644fb0e3..e4c80752ebd 100644
--- a/solr/core/src/java/org/apache/solr/cloud/Overseer.java
+++ b/solr/core/src/java/org/apache/solr/cloud/Overseer.java
@@ -152,7 +152,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";
@@ -271,8 +272,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);
@@ -336,8 +337,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);