保留租约无效的保留序列号异常 (retention_lease_invalid_retaining_sequence_number_exception) 错误排查与解决

# 查看索引的保留租约信息
GET /<index>/_stats?filter_path=**.retention_leases

# 查看特定分片的租约
GET /<index>/_stats?level=shards&filter_path=**.retention_leases

// 确保使用大于当前序列号的值
// 在更新租约前先检查当前序列号
long currentSeqNo = getCurrentRetainingSequenceNumber(leaseId);
long newSeqNo = Math.max(currentSeqNo, proposedSeqNo);
renewRetentionLease(leaseId, newSeqNo, ...);

# 确保操作的时序正确
# 检查操作日志
grep -i "retention.*lease\|sequence.*number" /path/to/easysearch/logs/easysearch.log | tail -100

# 确保集群状态同步
GET /_cluster/state?filter_path=**.retention_leases

# 等待集群稳定
GET /_cluster/health?wait_for_status=green&timeout=50s

# 如果租约状态混乱，可能需要删除并重建
# 注意：这可能导致数据丢失

# 如果节点状态异常，重启可能清理状态
sudo systemctl restart easysearch

# 等待节点启动
GET /_cat/nodes?v

# 对于跨集群复制，确保序列号同步
# 查看复制统计
GET /_ccr/stats

// 获取当前最大的序列号
long maxSeqNo = getMaxSeqNo();
long newRetainingSeqNo = maxSeqNo + 1;

// 使用新序列号更新租约
retentionLeases.renew(leaseId, newRetainingSeqNo, ...);

// 在更新租约前检查序列号
long existingSeqNo = getExistingRetainingSequenceNumber(leaseId);
if (proposedSeqNo < existingSeqNo) {
    // 使用现有序列号而非提议的序列号
    proposedSeqNo = existingSeqNo;
}

# 查看租约相关错误日志
grep -i "invalid.*retaining\|sequence.*number" /path/to/easysearch/logs/easysearch.log | tail -100

# 如果分片正在恢复，等待恢复完成
GET /_cat/recovery?v&active_only=true

# 等待恢复完成后再更新租约

# 确保分片状态正常
GET /_cat/shards?v&h=index,shard,prirep,state

# 查看分片统计信息
GET /<index>/_stats?level=shards

// 使用乐观锁处理并发更新
// 或使用同步机制确保更新的原子性
synchronized (leaseLock) {
    long currentSeqNo = getCurrentRetainingSequenceNumber(leaseId);
    if (proposedSeqNo >= currentSeqNo) {
        retentionLeases.renew(leaseId, proposedSeqNo, ...);
    }
}

// 如果序列号必须递增，使用增量的方式
long increment = 1000; // 或根据实际需求
long newSeqNo = ((currentSeqNo / increment) + 1) * increment;

# 如果问题持续存在，可能需要检查：
# - 集群配置
# - 节点版本兼容性
# - 数据完整性