首页 > 解决方案 > NiFi - 停止处理器后线程仍然运行

问题描述

我正在使用 Eclipse Milo 为 Apache NiFi 开发一个发布订阅处理器。我有一个服务来处理与 Eclipse Milo 和服务器的大部分交互,还有一个控制器,它基本上只是调用服务的功能。订阅 OPCUA 服务器上的节点工作正常,但我想不出终止订阅的好方法,例如当我停止处理器时。在服务中“存在”的订阅在服务被禁用以及控制器被禁用/停止后仍然存在。这意味着我定义的 @OnStopped 和 @OnUnscheduled 方法永远不会被调用,可能是因为订阅永远不会被终止。所以我不能使用这两种方法。我知道我可以终止 NiFi 1.7+ 中的线程,但我认为这不是处理这个问题的好方法,而且我 m 仍在使用 1.2。有没有人有什么建议?

标签: apache-nifi

解决方案


更新到最新版本,修复了处理器完成方式的一些问题。


推荐阅读