Nifi flow无法运行且显示活跃线程提示，如何恢复正常运行？

异常根因 #

• 运行时线程状态不一致：GenerateFlowFile的运行线程卡在NiFi进程的运行时缓存中，未被流程管理器正确回收。即使删除重建处理器，缓存的僵尸线程仍会关联到同类型处理器，最终出现线程计数浮动、无法禁用的异常。
  
• 存储库元数据损坏：FlowFile存储库或状态管理器中与该处理器关联的元数据出现损坏，导致处理器每次启动都卡在读写损坏数据的逻辑中，线程反复启停所以活跃/终止计数不停变动。
• 集群状态不同步（集群部署场景下）：单个节点上的处理器未收到集群同步的停止/禁用指令，前端展示的全局流状态与单节点实际运行状态不匹配，导致处理器无法被正常禁用。
  

修复操作步骤 #

1. 停止所有NiFi服务：单节点部署直接停止NiFi进程，集群环境下按顺序停止所有从节点后再停止主节点，确保没有残留运行线程。
2. 清理运行时缓存：进入NiFi安装根目录，删除work目录下的全部内容，该目录存储运行时的类缓存、线程临时状态，删除后重启会自动重建，可解决绝大多数线程状态残留问题。
3. 处理损坏的存储库：
   • 首先完整备份flowfile_repository、content_repository、provenance_repository三个目录，如果当前流没有需要保留的存量流文件，直接清空三个目录的所有内容，彻底消除元数据损坏的影响。
   • 如果之前为GenerateFlowFile配置了持久化状态，可备份后清空state目录的内容，清除处理器残留的异常持久化状态。
   • 生产环境可选操作：如果无法直接清空存储库，可在停止NiFi服务前执行jstack <NiFi进程ID> > nifi_thread_dump.log导出线程栈，找到卡死的GenerateFlowFile相关线程，确认阻塞点后针对性清理对应损坏的流文件数据即可。
4. 重启NiFi服务：单节点部署直接启动即可，集群环境先启动主节点，等待主节点完全运行后再依次启动从节点。
5. 服务启动完成后，重新创建GenerateFlowFile处理器并启动流验证功能是否恢复正常。

内容的提问来源于stack exchange，提问作者likeGreen