Выполнение конвейерного режима Azkaban приводит к сбою заданий после накопления достаточного количества заданий в заделе. Это происходит, если выполнение потока занимает больше времени, чем его частота планирования:
Есть ли способ заставить Azkaban запускать новый экземпляр только после того, как предыдущий закончился, при этом не пропуская ни одного экземпляра. Мы не можем пропустить экземпляры, поскольку параметр времени, передаваемый каждому, помогает выбрать продолжительность данных, которые должны быть обработаны.