You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by mm...@apache.org on 2022/02/15 13:08:48 UTC
[accumulo] branch main updated: Fix Fate goal message
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 <mm...@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: {