From 31766d2602b3a186ab06d730a38a71a499f55410 Mon Sep 17 00:00:00 2001 From: Dom G Date: Wed, 14 Oct 2026 18:02:43 -0400 Subject: [PATCH 1/2] Skip returning deleted fate txn info in monitor code --- .../org/apache/accumulo/monitor/next/SystemInformation.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/server/monitor/src/main/java/org/apache/accumulo/monitor/next/SystemInformation.java b/server/monitor/src/main/java/org/apache/accumulo/monitor/next/SystemInformation.java index 70dfe828cf6..aa378a64c05 100644 --- a/server/monitor/src/main/java/org/apache/accumulo/monitor/next/SystemInformation.java +++ b/server/monitor/src/main/java/org/apache/accumulo/monitor/next/SystemInformation.java @@ -1152,7 +1152,10 @@ public void processFateTransactions(List transactions) { transactions.forEach(t -> { FateOperation op = t.getFateOp(); TStatus status = t.getStatus(); - if (status == TStatus.SUBMITTED) { + if (status == TStatus.UNKNOWN) { + // the transaction was deleted while its info was being read, skip it + return; + } else if (status == TStatus.SUBMITTED) { instanceOverview.getTotalFateSubmitted().incrementAndGet(); if (op == FateOperation.TABLE_BULK_IMPORT2) { instanceOverview.getIngestBulkImportQueued().incrementAndGet(); From 3c92d2de86244addfe07c7a0bcd0132fba8bd4b8 Mon Sep 17 00:00:00 2001 From: Dom G Date: Wed, 14 Oct 2026 18:14:50 -0400 Subject: [PATCH 2/2] Add case to skipping transaction block --- .../org/apache/accumulo/monitor/next/SystemInformation.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/server/monitor/src/main/java/org/apache/accumulo/monitor/next/SystemInformation.java b/server/monitor/src/main/java/org/apache/accumulo/monitor/next/SystemInformation.java index aa378a64c05..1c8fd237a5a 100644 --- a/server/monitor/src/main/java/org/apache/accumulo/monitor/next/SystemInformation.java +++ b/server/monitor/src/main/java/org/apache/accumulo/monitor/next/SystemInformation.java @@ -1152,7 +1152,7 @@ public void processFateTransactions(List transactions) { transactions.forEach(t -> { FateOperation op = t.getFateOp(); TStatus status = t.getStatus(); - if (status == TStatus.UNKNOWN) { + if (status == TStatus.UNKNOWN || t.getTimeCreated() == 0) { // the transaction was deleted while its info was being read, skip it return; } else if (status == TStatus.SUBMITTED) {