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创建了大量的web连接，而且不会停止。

​

​

Answer 1

停止一个处理器实际上只是告诉调度器不要再触发任何执行。通常情况下，已经触发的线程在处理器停止后仍在执行，这就是添加Terminate选项的原因。