Skip to content

Commit

Permalink
Merge branch '3.1'
Browse files Browse the repository at this point in the history
  • Loading branch information
ctubbsii committed Sep 30, 2024
2 parents bc128fc + 26b3e4d commit fea968d
Show file tree
Hide file tree
Showing 11 changed files with 11 additions and 10 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -42,6 +42,7 @@ public static class Mapping {
private Collection<FileInfo> files;

// Gson requires a default constructor when JDK Unsafe usage is disabled
@SuppressWarnings("unused")
private Mapping() {}

public Mapping(KeyExtent tablet, Files files) {
Expand Down Expand Up @@ -71,6 +72,7 @@ public static class Tablet {
private byte[] prevEndRow;

// Gson requires a default constructor when JDK Unsafe usage is disabled
@SuppressWarnings("unused")
private Tablet() {}

public Tablet(Text endRow, Text prevEndRow) {
Expand Down Expand Up @@ -111,6 +113,7 @@ public static class FileInfo {
long estEntries;

// Gson requires a default constructor when JDK Unsafe usage is disabled
@SuppressWarnings("unused")
private FileInfo() {}

public FileInfo(String fileName, long estFileSize, long estNumEntries) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -228,6 +228,7 @@ private static class ServiceDescriptorGson {
private String group;

// default constructor required for Gson
@SuppressWarnings("unused")
public ServiceDescriptorGson() {}

public ServiceDescriptorGson(UUID uuid, ThriftService service, String address, String group) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -53,6 +53,7 @@ private static class Data {
private SortedMap<String,SortedSet<String>> candidates;

// Gson requires a default constructor when JDK Unsafe usage is disabled
@SuppressWarnings("unused")
private Data() {}

public Data(int version, SortedMap<String,SortedSet<String>> candidates) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -60,6 +60,7 @@ public class FateSummaryReport {
private transient Map<String,String> idsToNameMap;

// Gson requires a default constructor when JDK Unsafe usage is disabled
@SuppressWarnings("unused")
private FateSummaryReport() {}

public FateSummaryReport(Map<String,String> idsToNameMap, Set<FateId> fateIdFilter,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -40,6 +40,7 @@ public class FateTxnDetails implements Comparable<FateTxnDetails> {
private List<String> locksWaiting = List.of();

// Default constructor for Gson
@SuppressWarnings("unused")
private FateTxnDetails() {}

/**
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -53,6 +53,7 @@ public class ServiceStatusReport {
private Map<ReportKey,StatusSummary> summaries;

// Gson requires a default constructor when JDK Unsafe usage is disabled
@SuppressWarnings("unused")
private ServiceStatusReport() {}

public ServiceStatusReport(final Map<ReportKey,StatusSummary> summaries, final boolean noHosts) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -31,6 +31,7 @@ public class StatusSummary {
private int errorCount;

// Default constructor required for Gson
@SuppressWarnings("unused")
private StatusSummary() {}

public StatusSummary(ServiceStatusReport.ReportKey serviceType, final Set<String> resourceGroups,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -776,7 +776,7 @@ ScanReservation reserveFilesInstrumented(long scanId) throws NoSuchScanIDExcepti
}

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();
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -32,8 +32,6 @@
import org.apache.hadoop.fs.FileStatus;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

/**
* Write ahead logs have two paths in DFS. There is the path of the original unsorted walog and the
Expand All @@ -42,8 +40,6 @@
*/
public class ResolvedSortedLog {

private static final Logger log = LoggerFactory.getLogger(ResolvedSortedLog.class);

private final SortedSet<UnreferencedTabletFile> children;
private final LogEntry origin;
private final Path sortedLogDir;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -340,7 +340,7 @@ private long countZombieScans(long reportTimeMillis) {
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
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -35,8 +35,6 @@
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
Expand All @@ -45,8 +43,6 @@
*/
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;
Expand Down

0 comments on commit fea968d

Please sign in to comment.