Skip to content

Commit 252b1e2

Browse files
committed
Merge branch 'main' into elasticity
2 parents 878e4ed + 8bb8fce commit 252b1e2

File tree

3 files changed

+9
-3
lines changed

3 files changed

+9
-3
lines changed

core/src/main/java/org/apache/accumulo/core/conf/Property.java

-1
Original file line numberDiff line numberDiff line change
@@ -755,7 +755,6 @@ public enum Property {
755755
"The listening port for the garbage collector's monitor service.", "1.3.5"),
756756
GC_DELETE_THREADS("gc.threads.delete", "16", PropertyType.COUNT,
757757
"The number of threads used to delete RFiles and write-ahead logs.", "1.3.5"),
758-
@Experimental
759758
GC_REMOVE_IN_USE_CANDIDATES("gc.remove.in.use.candidates", "true", PropertyType.BOOLEAN,
760759
"GC will remove deletion candidates that are in-use from the metadata location. "
761760
+ "This is expected to increase the speed of subsequent GC runs.",

server/base/src/main/java/org/apache/accumulo/server/compaction/RetryableThriftCall.java

+8-1
Original file line numberDiff line numberDiff line change
@@ -95,11 +95,18 @@ public RetryableThriftCall(long start, long maxWaitTime, int maxNumRetries,
9595
*/
9696
public T run() throws RetriesExceededException {
9797
T result = null;
98+
var errorsSeen = 0;
9899
do {
99100
try {
100101
result = function.execute();
101102
} catch (TException e) {
102-
LOG.error("Error in Thrift function, retrying ...", e);
103+
errorsSeen++;
104+
// Log higher levels of errors on every 5th error
105+
if (errorsSeen >= 5 && errorsSeen % 5 == 0) {
106+
LOG.warn("Error in Thrift function, retrying ...", e);
107+
} else {
108+
LOG.debug("Error in Thrift function, retrying ...", e);
109+
}
103110
}
104111
if (result == null) {
105112
if (this.retry.canRetry()) {

server/tserver/src/main/java/org/apache/accumulo/tserver/ScanServer.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -915,7 +915,7 @@ batchTimeOut, classLoaderContext, executionHints, getScanTabletResolver(tablet),
915915
public ScanResult continueScan(TInfo tinfo, long scanID, long busyTimeout)
916916
throws NoSuchScanIDException, NotServingTabletException, TooManyFilesException,
917917
TSampleNotPresentException, TException {
918-
LOG.debug("continue scan: {}", scanID);
918+
LOG.trace("continue scan: {}", scanID);
919919

920920
try (ScanReservation reservation = reserveFiles(scanID)) {
921921
Preconditions.checkState(reservation.getFailures().isEmpty());

0 commit comments

Comments
 (0)