(accumulo) branch main updated: adds back some removed, needed FATE code from 5817 (#5829)

[krathbun]

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

krathbun pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/accumulo.git


The following commit(s) were added to refs/heads/main by this push:
     new 93feaed6fd adds back some removed, needed FATE code from 5817 (#5829)
93feaed6fd is described below

commit 93feaed6fdd2cc5fb72e2c4691eecf52d129ef3a
Author: Kevin Rathbun <krath...@apache.org>
AuthorDate: Mon Aug 25 16:22:04 2025 -0400

    adds back some removed, needed FATE code from 5817 (#5829)
    
    PR #5817 removed some code in the handling of RejectedExecutionException
    that is still needed
---
 .../main/java/org/apache/accumulo/core/fate/FateExecutor.java  | 10 +++++++++-
 1 file changed, 9 insertions(+), 1 deletion(-)

diff --git a/core/src/main/java/org/apache/accumulo/core/fate/FateExecutor.java 
b/core/src/main/java/org/apache/accumulo/core/fate/FateExecutor.java
index 56a6c17f44..97fca25a43 100644
--- a/core/src/main/java/org/apache/accumulo/core/fate/FateExecutor.java
+++ b/core/src/main/java/org/apache/accumulo/core/fate/FateExecutor.java
@@ -122,7 +122,15 @@ public class FateExecutor<T> {
             transactionExecutor.execute(tr);
           } catch (RejectedExecutionException e) {
             runningTxRunners.remove(tr);
-            log.error("Unexpected error adding transaction runner to FaTE 
executor pool.", e);
+            // RejectedExecutionException could be shutting down
+            if (transactionExecutor.isShutdown()) {
+              // The exception is expected in this case, no need to spam the 
logs.
+              log.trace("Expected error adding transaction runner to FaTE 
executor pool. "
+                  + "The pool is shutdown.", e);
+            } else {
+              // This is bad, FaTE may no longer work!
+              log.error("Unexpected error adding transaction runner to FaTE 
executor pool.", e);
+            }
             break;
           }
         }