如何在 NiFi RouteOnAttribute 中评估 "Node Address"
How to evaluate "Node Address" in NiFi RouteOnAttribute
我们的 3 个 nifi 节点中的一个出现了问题,我在该节点上积压了大量流文件,现在也阻塞了其他节点的流文件。
我希望能够拆分节点 3 流文件,以便可以继续处理节点 1 和 2 流文件。我希望有一种方法可以使用 RouteOnAttribute 处理器来评估流文件的节点地址,但我似乎找不到正确的属性。
有什么办法吗?
尝试这些属性 - ${hostname()} 或 ${nodeAddress}
我们的 3 个 nifi 节点中的一个出现了问题,我在该节点上积压了大量流文件,现在也阻塞了其他节点的流文件。
我希望能够拆分节点 3 流文件,以便可以继续处理节点 1 和 2 流文件。我希望有一种方法可以使用 RouteOnAttribute 处理器来评估流文件的节点地址,但我似乎找不到正确的属性。
有什么办法吗?
尝试这些属性 - ${hostname()} 或 ${nodeAddress}