Отсрочка распределения при выходе узла из кластера

Когда узел по каким-либо причинам, намеренно или непреднамеренно, покидает кластер, мастер реагирует следующим образом:

Эти действия предназначены для защиты кластера от потери данных, гарантируя, что каждый фрагмент будет полностью дублирован как можно быстрее.

Несмотря на то, что мы ограничиваем одновременные восстановления как на уровне узла, так и на уровне кластера, эта «перетасовка фрагментов» всё ещё может накладывать значительную нагрузку на кластер, что может быть не нужно, если отсутствующий узел, вероятно, скоро вернётся. Представьте себе такую ситуацию:

Если бы мастер просто подождал несколько минут, отсутствующие фрагменты можно было бы перераспределить на узел 5 с минимальным объёмом сетевого трафика. Этот процесс будет ещё быстрее для простаивающих фрагментов (фрагментов, не получающих запросы индексирования), которые автоматически очищаются.

Распределение фрагментов-реплик, которые становятся неназначенными из-за выхода узла, можно отсрочить с помощью динамической настройки index.unassigned.node_left.delayed_timeout, которая по умолчанию равна 1m.

Данную настройку можно обновить в активном индексе (или для всех индексов):

resp = client.indices.put_settings(
    index="_all",
    settings={
        "settings": {
            "index.unassigned.node_left.delayed_timeout": "5m"
        }
    },
)
print(resp)

response = client.indices.put_settings(
  index: '_all',
  body: {
    settings: {
      'index.unassigned.node_left.delayed_timeout' => '5m'
    }
  }
)
puts response

const response = await client.indices.putSettings({
  index: "_all",
  settings: {
    settings: {
      "index.unassigned.node_left.delayed_timeout": "5m",
    },
  },
});
console.log(response);

PUT _all/_settings
{
  "settings": {
    "index.unassigned.node_left.delayed_timeout": "5m"
  }
}

При включённой отсрочке распределения описанный сценарий изменяется следующим образом:

resp = client.cluster.health()
print(resp)

response = client.cluster.health
puts response

const response = await client.cluster.health();
console.log(response);

GET _cluster/health 

resp = client.indices.put_settings(
    index="_all",
    settings={
        "settings": {
            "index.unassigned.node_left.delayed_timeout": "0"
        }
    },
)
print(resp)

response = client.indices.put_settings(
  index: '_all',
  body: {
    settings: {
      'index.unassigned.node_left.delayed_timeout' => '0'
    }
  }
)
puts response

const response = await client.indices.putSettings({
  index: "_all",
  settings: {
    settings: {
      "index.unassigned.node_left.delayed_timeout": "0",
    },
  },
});
console.log(response);

PUT _all/_settings
{
  "settings": {
    "index.unassigned.node_left.delayed_timeout": "0"
  }
}