honeymoose/OpenSearch
1
0
Fork 0
mirror of https://github.com/honeymoose/OpenSearch.git synced 2025-03-25 17:38:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

Include in log retention leases that failed to sync

Browse Source 
When retention leases fail to sync after an expiration check, we emit a
log message about this. This commit adds the retention leases that
failed to sync.
This commit is contained in:
Jason Tedor 2019-02-18 15:06:54 -05:00
parent bbb61002ba
commit d43ac8fe11
No known key found for this signature in database
GPG Key ID: FA89F05560F16BC5
1 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
server/src/main/java/org/elasticsearch/index/shard/IndexShard.java
View File

@ -21,6 +21,7 @@ package org.elasticsearch.index.shard;
import com.carrotsearch.hppc.ObjectLongMap;
import org.apache.logging.log4j.Logger;
import org.apache.logging.log4j.message.ParameterizedMessage;
import org.apache.lucene.index.CheckIndex;
import org.apache.lucene.index.IndexCommit;
import org.apache.lucene.index.SegmentInfos;
@ -2015,7 +2016,12 @@ public class IndexShard extends AbstractIndexShardComponent implements IndicesCl
retentionLeaseSyncer.sync(
shardId,
retentionLeases.v2(),
ActionListener.wrap(r -> {}, e -> logger.warn("failed to sync retention leases after expiration check", e)));
ActionListener.wrap(
r -> {},
e -> logger.warn(new ParameterizedMessage(
"failed to sync retention leases [{}] after expiration check",
retentionLeases),
e)));
} else {
logger.trace("background syncing retention leases [{}] after expiration check", retentionLeases.v2());
retentionLeaseSyncer.backgroundSync(shardId, retentionLeases.v2());