Throw exception on Unknown status return

apache · Aug 5, 2024 · 5882212 · 5882212
1 parent 90023e5
commit 5882212
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/core/src/main/java/org/apache/accumulo/core/fate/user/UserFateStore.java b/core/src/main/java/org/apache/accumulo/core/fate/user/UserFateStore.java
@@ -106,7 +106,11 @@ public FateId create() {
         case ACCEPTED:
           return fateId;
         case UNKNOWN:
+          log.error("Fate creation returned UNKNOWN status, raising exception");
+          throw new IllegalStateException("Fate creation returned UNKNOWN status");
         case REJECTED:
+          log.debug(
+              "Fate creation returned REJECTED status (most likely FateId collision), retrying...");
           attempt++;
           continue;
         default: