This is an automated email from the ASF dual-hosted git repository.
ctubbsii pushed a commit to branch 2.1
in repository https://gitbox.apache.org/repos/asf/accumulo.git
The following commit(s) were added to refs/heads/2.1 by this push:
new 3ec800b9b9 Fix trivial warnings
3ec800b9b9 is described below
commit 3ec800b9b9225e1b2d31efb9cd269c6c72666ef1
Author: Christopher Tubbs <[email protected]>
AuthorDate: Thu Sep 19 15:19:45 2024 -0400
Fix trivial warnings
* Avoid raw generic on ScanSession
* Remove unused Logger
---
.../tserver/src/main/java/org/apache/accumulo/tserver/ScanServer.java | 2 +-
.../main/java/org/apache/accumulo/tserver/session/SessionManager.java | 2 +-
.../main/java/org/apache/accumulo/tserver/tablet/SnapshotTablet.java | 4 ----
3 files changed, 2 insertions(+), 6 deletions(-)
diff --git
a/server/tserver/src/main/java/org/apache/accumulo/tserver/ScanServer.java
b/server/tserver/src/main/java/org/apache/accumulo/tserver/ScanServer.java
index 0e74b8c732..688a08b171 100644
--- a/server/tserver/src/main/java/org/apache/accumulo/tserver/ScanServer.java
+++ b/server/tserver/src/main/java/org/apache/accumulo/tserver/ScanServer.java
@@ -757,7 +757,7 @@ public class ScanServer extends AbstractServer
}
protected ScanReservation reserveFiles(long scanId) throws
NoSuchScanIDException {
- var session = (ScanSession) sessionManager.getSession(scanId);
+ var session = (ScanSession<?>) sessionManager.getSession(scanId);
if (session == null) {
throw new NoSuchScanIDException();
}
diff --git
a/server/tserver/src/main/java/org/apache/accumulo/tserver/session/SessionManager.java
b/server/tserver/src/main/java/org/apache/accumulo/tserver/session/SessionManager.java
index 497287cda6..d1bf4d6f8c 100644
---
a/server/tserver/src/main/java/org/apache/accumulo/tserver/session/SessionManager.java
+++
b/server/tserver/src/main/java/org/apache/accumulo/tserver/session/SessionManager.java
@@ -350,7 +350,7 @@ public class SessionManager {
return Stream.concat(deferredCleanupQueue.stream(),
sessions.values().stream())
.filter(session -> {
if (session instanceof ScanSession) {
- var scanSession = (ScanSession) session;
+ var scanSession = (ScanSession<?>) session;
synchronized (scanSession) {
var scanTask = scanSession.getScanTask();
if (scanTask != null && scanSession.getState() == State.REMOVED
diff --git
a/server/tserver/src/main/java/org/apache/accumulo/tserver/tablet/SnapshotTablet.java
b/server/tserver/src/main/java/org/apache/accumulo/tserver/tablet/SnapshotTablet.java
index 985f7339dd..c2de47120b 100644
---
a/server/tserver/src/main/java/org/apache/accumulo/tserver/tablet/SnapshotTablet.java
+++
b/server/tserver/src/main/java/org/apache/accumulo/tserver/tablet/SnapshotTablet.java
@@ -36,8 +36,6 @@ import org.apache.accumulo.tserver.InMemoryMap;
import org.apache.accumulo.tserver.TabletHostingServer;
import org.apache.accumulo.tserver.TabletServerResourceManager;
import org.apache.accumulo.tserver.metrics.TabletServerScanMetrics;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
/**
* A tablet that can not be written to and operates off of a snapshot of
tablet metadata for its
@@ -46,8 +44,6 @@ import org.slf4j.LoggerFactory;
*/
public class SnapshotTablet extends TabletBase {
- private static final Logger log =
LoggerFactory.getLogger(SnapshotTablet.class);
-
private final TabletHostingServer server;
private final SortedMap<StoredTabletFile,DataFileValue> files;
private final TabletServerResourceManager.TabletResourceManager
tabletResources;