This is an automated email from the ASF dual-hosted git repository. ctubbsii pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/accumulo.git
commit 7bbd5620507add66c9313822729b8acc55110e82 Author: Christopher Tubbs <ctubb...@apache.org> AuthorDate: Tue Mar 25 21:32:34 2025 -0400 Fix some warnings in Fate code --- .../src/main/java/org/apache/accumulo/core/fate/user/UserFateStore.java | 2 -- .../src/main/java/org/apache/accumulo/manager/split/Splitter.java | 1 + .../main/java/org/apache/accumulo/test/fate/FateExecutionOrderIT.java | 2 +- .../src/main/java/org/apache/accumulo/test/fate/FatePoolsWatcherIT.java | 2 +- test/src/main/java/org/apache/accumulo/test/fate/FateTestRunner.java | 2 +- 5 files changed, 4 insertions(+), 5 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 index de292ec0c4..311c2890dd 100644 --- 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 @@ -54,11 +54,9 @@ import org.apache.accumulo.core.fate.Fate.TxInfo; import org.apache.accumulo.core.fate.FateId; import org.apache.accumulo.core.fate.FateInstanceType; import org.apache.accumulo.core.fate.FateKey; -import org.apache.accumulo.core.fate.FateKey.FateKeyType; import org.apache.accumulo.core.fate.ReadOnlyRepo; import org.apache.accumulo.core.fate.Repo; import org.apache.accumulo.core.fate.StackOverflowException; -import org.apache.accumulo.core.fate.user.FateMutator.Status; import org.apache.accumulo.core.fate.user.schema.FateSchema.RepoColumnFamily; import org.apache.accumulo.core.fate.user.schema.FateSchema.TxColumnFamily; import org.apache.accumulo.core.fate.user.schema.FateSchema.TxInfoColumnFamily; diff --git a/server/manager/src/main/java/org/apache/accumulo/manager/split/Splitter.java b/server/manager/src/main/java/org/apache/accumulo/manager/split/Splitter.java index d88e52ed66..724615f41e 100644 --- a/server/manager/src/main/java/org/apache/accumulo/manager/split/Splitter.java +++ b/server/manager/src/main/java/org/apache/accumulo/manager/split/Splitter.java @@ -105,6 +105,7 @@ public class Splitter { if (!splits.isEmpty()) { try (var seeder = manager.fate(instanceType).beginSeeding()) { for (KeyExtent extent : splits.values()) { + @SuppressWarnings("unused") var unused = seeder.attemptToSeedTransaction(Fate.FateOperation.SYSTEM_SPLIT, FateKey.forSplit(extent), new FindSplits(extent), true); } diff --git a/test/src/main/java/org/apache/accumulo/test/fate/FateExecutionOrderIT.java b/test/src/main/java/org/apache/accumulo/test/fate/FateExecutionOrderIT.java index f798e0d93d..ba01be9990 100644 --- a/test/src/main/java/org/apache/accumulo/test/fate/FateExecutionOrderIT.java +++ b/test/src/main/java/org/apache/accumulo/test/fate/FateExecutionOrderIT.java @@ -67,7 +67,7 @@ import com.google.common.collect.Iterators; public abstract class FateExecutionOrderIT extends SharedMiniClusterBase implements FateTestRunner<FateExecutionOrderIT.FeoTestEnv> { - public static class FeoTestEnv extends TestEnv { + public static class FeoTestEnv extends FateTestRunner.TestEnv { private final AccumuloClient client; public FeoTestEnv(AccumuloClient client) { diff --git a/test/src/main/java/org/apache/accumulo/test/fate/FatePoolsWatcherIT.java b/test/src/main/java/org/apache/accumulo/test/fate/FatePoolsWatcherIT.java index 1245b24e47..51993a564b 100644 --- a/test/src/main/java/org/apache/accumulo/test/fate/FatePoolsWatcherIT.java +++ b/test/src/main/java/org/apache/accumulo/test/fate/FatePoolsWatcherIT.java @@ -714,7 +714,7 @@ public abstract class FatePoolsWatcherIT extends SharedMiniClusterBase } } - public static class PoolResizeTestEnv extends TestEnv { + public static class PoolResizeTestEnv extends FateTestRunner.TestEnv { private final AtomicInteger numWorkers = new AtomicInteger(0); private final CountDownLatch isReadyLatch = new CountDownLatch(1); } diff --git a/test/src/main/java/org/apache/accumulo/test/fate/FateTestRunner.java b/test/src/main/java/org/apache/accumulo/test/fate/FateTestRunner.java index dc9b7d22fc..1b8ac0ab6b 100644 --- a/test/src/main/java/org/apache/accumulo/test/fate/FateTestRunner.java +++ b/test/src/main/java/org/apache/accumulo/test/fate/FateTestRunner.java @@ -43,7 +43,7 @@ public interface FateTestRunner<T extends TestEnv> { void execute(FateStore<T> store, ServerContext sctx) throws Exception; } - class TestEnv { + static class TestEnv { } }