diff --git a/server/src/main/java/org/elasticsearch/index/shard/IndexShard.java b/server/src/main/java/org/elasticsearch/index/shard/IndexShard.java index 50400c6961741..4bdad8d5ec328 100644 --- a/server/src/main/java/org/elasticsearch/index/shard/IndexShard.java +++ b/server/src/main/java/org/elasticsearch/index/shard/IndexShard.java @@ -2011,8 +2011,13 @@ public void syncRetentionLeases() { verifyNotClosed(); final Tuple retentionLeases = getRetentionLeases(true); if (retentionLeases.v1()) { - retentionLeaseSyncer.sync(shardId, retentionLeases.v2(), ActionListener.wrap(() -> {})); + logger.trace("syncing retention leases [{}] after expiration check", retentionLeases.v2()); + retentionLeaseSyncer.sync( + shardId, + retentionLeases.v2(), + ActionListener.wrap(r -> {}, e -> logger.warn("failed to sync retention leases after expiration check", e))); } else { + logger.trace("background syncing retention leases [{}] after expiration check", retentionLeases.v2()); retentionLeaseSyncer.backgroundSync(shardId, retentionLeases.v2()); } }