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
The following commit(s) were added to refs/heads/main by this push:
new 40dc910caa Fix trivial unused variable warnings
40dc910caa is described below
commit 40dc910caa840e7aa94f6f17b0521aa80a270050
Author: Christopher Tubbs <[email protected]>
AuthorDate: Wed Nov 27 18:40:41 2024 -0500
Fix trivial unused variable warnings
* Remove 2 unused variables
* Fix unused variable in ZookeeperLockCheckerTest by restoring the
deleted test case by copying the original code from the 3.1 branch,
and updating the implementation to match on a mock object
---
.../core/clientImpl/ZookeeperLockCheckerTest.java | 19 +++++++++++++++++--
.../java/org/apache/accumulo/test/fate/FateIT.java | 1 -
.../accumulo/test/fate/user/UserFateStoreIT.java | 3 ---
3 files changed, 17 insertions(+), 6 deletions(-)
diff --git
a/core/src/test/java/org/apache/accumulo/core/clientImpl/ZookeeperLockCheckerTest.java
b/core/src/test/java/org/apache/accumulo/core/clientImpl/ZookeeperLockCheckerTest.java
index b047bbc3aa..9629c69ffc 100644
---
a/core/src/test/java/org/apache/accumulo/core/clientImpl/ZookeeperLockCheckerTest.java
+++
b/core/src/test/java/org/apache/accumulo/core/clientImpl/ZookeeperLockCheckerTest.java
@@ -18,13 +18,18 @@
*/
package org.apache.accumulo.core.clientImpl;
+import static org.easymock.EasyMock.anyObject;
import static org.easymock.EasyMock.createMock;
import static org.easymock.EasyMock.expect;
+import static org.easymock.EasyMock.expectLastCall;
import static org.easymock.EasyMock.replay;
+import static org.easymock.EasyMock.verify;
+
+import java.util.function.Predicate;
import org.apache.accumulo.core.fate.zookeeper.ZooCache;
-import org.apache.accumulo.core.lock.ServiceLockPaths;
import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
public class ZookeeperLockCheckerTest {
private ClientContext context;
@@ -37,8 +42,18 @@ public class ZookeeperLockCheckerTest {
expect(context.getZooKeeperRoot()).andReturn("/accumulo/iid").anyTimes();
zc = createMock(ZooCache.class);
expect(context.getZooCache()).andReturn(zc).anyTimes();
- expect(context.getServerPaths()).andReturn(new
ServiceLockPaths(context)).anyTimes();
replay(context);
zklc = new ZookeeperLockChecker(context);
}
+
+ @Test
+ public void testInvalidateCache() {
+ @SuppressWarnings("unchecked")
+ Predicate<String> anyObj = anyObject(Predicate.class);
+ zc.clear(anyObj);
+ expectLastCall();
+ replay(zc);
+ zklc.invalidateCache("server");
+ verify(zc);
+ }
}
diff --git a/test/src/main/java/org/apache/accumulo/test/fate/FateIT.java
b/test/src/main/java/org/apache/accumulo/test/fate/FateIT.java
index d36e98bdec..d128f24a65 100644
--- a/test/src/main/java/org/apache/accumulo/test/fate/FateIT.java
+++ b/test/src/main/java/org/apache/accumulo/test/fate/FateIT.java
@@ -490,7 +490,6 @@ public abstract class FateIT extends SharedMiniClusterBase
implements FateTestRu
protected void testNoWriteAfterDelete(FateStore<TestEnv> store,
ServerContext sctx)
throws Exception {
- final String tableName = getUniqueNames(1)[0];
final FateId fateId = store.create();
final Repo<TestEnv> repo = new TestRepo("testNoWriteAfterDelete");
diff --git
a/test/src/main/java/org/apache/accumulo/test/fate/user/UserFateStoreIT.java
b/test/src/main/java/org/apache/accumulo/test/fate/user/UserFateStoreIT.java
index c82662182c..ead901b7ed 100644
--- a/test/src/main/java/org/apache/accumulo/test/fate/user/UserFateStoreIT.java
+++ b/test/src/main/java/org/apache/accumulo/test/fate/user/UserFateStoreIT.java
@@ -39,7 +39,6 @@ import org.apache.accumulo.core.data.Range;
import org.apache.accumulo.core.data.Value;
import org.apache.accumulo.core.fate.AbstractFateStore;
import org.apache.accumulo.core.fate.FateId;
-import org.apache.accumulo.core.fate.FateInstanceType;
import org.apache.accumulo.core.fate.FateStore;
import org.apache.accumulo.core.fate.ReadOnlyFateStore.TStatus;
import org.apache.accumulo.core.fate.user.UserFateStore;
@@ -62,8 +61,6 @@ import com.google.common.collect.MoreCollectors;
public class UserFateStoreIT extends SharedMiniClusterBase {
- private static final FateInstanceType fateInstanceType =
FateInstanceType.USER;
-
@BeforeAll
public static void setup() throws Exception {
SharedMiniClusterBase.startMiniCluster();