NiFi - 停止处理器后线程仍在运行



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

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

最新更新