Отказоустойчивое выполнение запросов в кластере Managed Service for Trino

Отказоустойчивое выполнение запросов в кластере Managed Service for Trino обеспечивается механизмом Fault tolerant execution. По умолчанию при недостатке ресурсов или ошибке при выполнении запроса воркер прекращает его обработку. Такой запрос нужно перезапустить вручную. При включении Fault tolerant execution запрос или промежуточное задание в составе запроса будут выполнены повторно в случае сбоя.

Чтобы обеспечить отказоустойчивое выполнение запросов при включенном Fault tolerant execution, Exchange Manager периодически выгружает промежуточные результаты в служебный бакет Object Storage. Если запрос не был выполнен, то координатор назначит повторное выполнение запроса другому воркеру, который сможет использовать ранее обработанные данные.

Механизм Fault tolerant execution поддерживается только для следующих коннекторов:

• Delta Lake
• Hive
• Iceberg
• Oracle Preview
• PostgreSQL
• MS SQL Server Preview

Чтобы включить Fault tolerant execution, при создании или изменении кластера выберите в блоке Политика перезапросов значение параметра Тип объекта для перезапроса:

• Задача — в рамках запроса повторно выполняется промежуточное задание, вызвавшее сбой воркера.

  Важно

  При интенсивном потоке простых запросов повторный запуск заданий может привести к более высокой задержке сложных пакетных запросов. Рекомендуется создать выделенный кластер Managed Service for Trino с настройкой повторного выполнения заданий для сложных пакетных запросов.

• Запрос — повторно выполняются все этапы запроса, в котором произошел сбой воркера.

Подробнее об отказоустойчивом выполнении запросов в официальной документации.