NIFI工作流失败条目

Question

我只有几个处理器，例如Select Hive和Put HDFS，当工作流程中的任何一个处理器出现故障时，我都需要一种现代的方法将Hive查询插入表中。

P.S，我尝试通过渠道连接所有失败条目，但任何更好的想法都将不胜感激。

Answer 1

这是使用渠道的好方法。我建议您将另一个进程组用于处理错误。主要是为了以后更好地监视流量，如：：>

您还可以使用输入和输出端口来提供良好的可见性，并且可以以不同方式处理每个错误。

例如：

在主流程中设置输出端口：

使用输入端口处理不同进程组中的每个错误：

然后都依靠：