В NiFi я хочу выполнять SQL-запрос каждый час, потому что мне нужно извлекать записи, добавленные за последний час. Запрос может занять от 5 минут до более 1 часа! Я подготовил свой ExecuteSQL и пытался планировать каждый час. Учитывая тот факт, что запрос может занять больше, чем это время, выполнение не вовремя, поэтому бывает, что я потерял целый час записей.
Я думал о выполнении CRON, чтобы точно запустить запроскаждый час. Но что, если это займет более 1 часа? Могут ли одновременно выполняться 2 задания? Я имею в виду, если задание на 13:00 все еще выполняется и извлекает записи с 12:00 до 13:00, можно ли запустить задание на 14:00 и извлечь записи с 13:00 до 14:00? ?
Большое спасибо за помощь!