保留租约已存在异常 (retention_lease_already_exists_exception) 错误排查与解决

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

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

// 确保使用唯一的租约 ID
// 可以使用 UUID 或其他唯一标识符
String leaseId = UUID.randomUUID().toString();

// 或使用有意义的唯一前缀
String leaseId = "consumer_" + consumerId + "_" + System.currentTimeMillis();

// 在创建租约前检查是否已存在
// 如果存在，可以续约而非创建新租约

# 如果需要重新创建租约，先删除现有的
# 注意：这可能导致数据丢失

# 通过 API 删除租约（如果支持）

// 如果租约已存在，续约而非创建
// 使用相同的租约 ID 进行续约
retentionLeases.renew(leaseId, retainingSequenceNumber, timestamp);

// 在客户端实现幂等操作
// 检查租约是否存在，再决定创建或续约
try {
    createRetentionLease(leaseId, ...);
} catch (RetentionLeaseAlreadyExistsException e) {
    // 租约已存在，续约即可
    renewRetentionLease(leaseId, ...);
}

# 对于跨集群复制，确保租约 ID 唯一
# 可以添加集群前缀
PUT /_cluster/settings
{
  "persistent": {
    "cluster.remote.cluster2.leas_id_prefix": "cluster2_"
  }
}

# 如果是临时性冲突，短暂延迟后重试
# 实现指数退避重试机制

# 查看租约相关错误日志
grep -i "retention.*lease\|lease.*exists" /path/to/easysearch/logs/easysearch.log | tail -100

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

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

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

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

// 可以使用不同的租约 ID 生成策略
// 例如基于消费者类型、时间等
String leaseId = consumerType + "_" + date + "_" + sequenceId;

# 清理不再需要的过期租约
// 可以通过 API 手动清理或配置自动清理

# 如果从快照恢复导致租约冲突
// 检查快照中的租约状态
GET /_snapshot/<repository>/<snapshot_name>

// 考虑不恢复租约信息
POST /_snapshot/<repository>/<snapshot_name>/_restore
{
  "indices": "<index>",
  "include_global_state": false
}

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

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