NiFi - Процессор остановлен, но задача все еще выполняется

Question

В наши дни работает нормально. Внезапно процессоры все еще имеют запущенную задачу, даже если она была остановлена, и выполняющуюся задачу необходимо завершить вручную.

Есть мысли?

обновление 1

Я использую nipyapi , чтобы манипулировать некоторыми процессорами, чтобы запускать и останавливать снова и снова. Есть API, которые я использовал

nipyapi.canvas.get_processor(identifier=p_id, identifier_type='id')
nipyapi.canvas.get_process_group(identifier=pg_id, identifier_type='id')
nipyapi.canvas.schedule_processor(processor=p_id, scheduled=True, refresh=True)

Я перезагружаю NiFi и проблема решается, но после многократного выполнения этих API (около 10000 раз, grep processor id | wc -l) возникает проблема.

Я считаю, что эти API создают много веб-соединений и не останавливаются.

Answer 1

Остановка процессора - это просто указание планировщику не запускать больше выполнений.Часто уже запущенный поток все еще выполняется после остановки процессора, поэтому была добавлена ​​опция Terminate.