This is an automated email from the ASF dual-hosted git repository. mmiller 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 afe4791 Fix Fate goal message afe4791 is described below commit afe4791a673ee039138d5f8e8a8f608dea19f57e Author: Mike Miller <mmil...@apache.org> AuthorDate: Tue Feb 15 08:04:21 2022 -0500 Fix Fate goal message --- core/src/main/java/org/apache/accumulo/fate/Fate.java | 2 +- .../src/main/java/org/apache/accumulo/manager/FateServiceHandler.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/core/src/main/java/org/apache/accumulo/fate/Fate.java b/core/src/main/java/org/apache/accumulo/fate/Fate.java index 769bf77..a2559ea 100644 --- a/core/src/main/java/org/apache/accumulo/fate/Fate.java +++ b/core/src/main/java/org/apache/accumulo/fate/Fate.java @@ -274,7 +274,7 @@ public class Fate<T> { if (store.getStatus(tid) == TStatus.NEW) { if (store.top(tid) == null) { try { - log.info("Seeding {} goal: {}", FateTxId.formatTid(tid), goalMessage); + log.info("Seeding {} {}", FateTxId.formatTid(tid), goalMessage); store.push(tid, repo); } catch (StackOverflowException e) { // this should not happen diff --git a/server/manager/src/main/java/org/apache/accumulo/manager/FateServiceHandler.java b/server/manager/src/main/java/org/apache/accumulo/manager/FateServiceHandler.java index 1dbd5b6..2f2da48 100644 --- a/server/manager/src/main/java/org/apache/accumulo/manager/FateServiceHandler.java +++ b/server/manager/src/main/java/org/apache/accumulo/manager/FateServiceHandler.java @@ -113,7 +113,7 @@ class FateServiceHandler implements FateService.Iface { List<ByteBuffer> arguments, Map<String,String> options, boolean autoCleanup) throws ThriftSecurityException, ThriftTableOperationException { authenticate(c); - String goalMessage = "Op: " + op.toString() + " "; + String goalMessage = op.toString() + " "; switch (op) { case NAMESPACE_CREATE: {