Skip to content

Commit d832f1c

Browse files
Extend NamedBlobMysqlDatabasePerf tool for more tests
1 parent ad13d1b commit d832f1c

File tree

3 files changed

+574
-273
lines changed

3 files changed

+574
-273
lines changed

ambry-commons/src/main/java/com/github/ambry/commons/RetryExecutor.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -65,7 +65,7 @@ private <T> void recursiveAsyncRetry(Consumer<Callback<T>> call, Predicate<Throw
6565
int currAttempts = attempts + 1;
6666
if (currAttempts < policy.maxAttempts() && isRetriable.test(exception)) {
6767
int waitTimeMs = policy.waitTimeMs(currAttempts);
68-
logger.info("{} of {} attempts failed, will keep retrying after a {} ms backoff. exception='{}'",
68+
logger.trace("{} of {} attempts failed, will keep retrying after a {} ms backoff. exception='{}'",
6969
currAttempts, policy.maxAttempts(), waitTimeMs, exception);
7070
//Don't need the scheduler if no need to wait for retry and show warn message if scheduler is null but wait time larger than 0;
7171
if (scheduler == null) {
@@ -78,7 +78,7 @@ private <T> void recursiveAsyncRetry(Consumer<Callback<T>> call, Predicate<Throw
7878
waitTimeMs, TimeUnit.MILLISECONDS);
7979
}
8080
} else {
81-
logger.info("{} of {} attempts failed, completing operation. See exception below:", currAttempts,
81+
logger.trace("{} of {} attempts failed, completing operation. See exception below:", currAttempts,
8282
policy.maxAttempts(), exception);
8383
userCallback.onCompletion(null, exception);
8484
}

0 commit comments

Comments
 (0)