Support WRITE_BEHIND retry mechanism: correct checkstyle

Signed-off-by: zzhlhc <zhouzh_zzz@qq.com>
pull/5294/head
zzhlhc 1 year ago
parent 45f7ac5a81
commit a09622d238

@ -84,7 +84,12 @@ public class MapWriteBehindTask {
}
private void flushTasks(Map<Object, Object> addedMap, List<Object> deletedKeys) {
final RetryableWriter retryableWriter = options.getWriter() == null ? options.getWriterAsync() : options.getWriter();
final RetryableWriter retryableWriter;
if (options.getWriter() != null) {
retryableWriter = options.getWriter();
} else {
retryableWriter = options.getWriterAsync();
}
//execute at least once
final int leftAttempts = Math.max(1, retryableWriter.getRetryAttempts());

Loading…
Cancel
Save