在 Apache NiFi 中获取失败原因

Question

我想记录一些 NiFi 处理器失败的原因。但我看到它可能有多种原因。

SplitAvroJson 处理器示例：“如果 FlowFile 由于任何原因处理失败（例如，FlowFile 不是有效的 Avro），它将被路由到此关系”

是否有可能获得我失败的确切原因以便将其保存在例如放置文件中？

先感谢您。

Answer 1

大多数处理器会将错误记录到 nifi-app.log 中。对于 SplitAvro 的示例，它在这里执行此操作：

https://github.com/apache/nifi/blob/e4b7e47836edf47042973e604005058c28eed23b/nifi-nar-bundles/nifi-avro-bundle/nifi-avro-processors/src/main/java/org/apache/nifi/processors/avro/ SplitAvro.java#L206

此错误消息也将作为 SplitAvro 处理器上的公告显示在 NiFi UI 中。

这能达到您想要的效果吗？