如何为处理器设置默认 'Run Schedule'

Question

我经常使用 GenerateFlowFile 处理器来测试其他处理器的行为并了解流程。但是每次，我都忘记更改默认值 'Run Schedule'，默认情况下为“0”。在我意识到它用数千个文件轰炸流程之前。

有没有办法改变默认值？有时真的很沮丧。

Answer 1

没有办法在不更改代码的情况下做到这一点。

可以在处理器上使用一个注释来指示默认调度选项：

@DefaultSchedule(strategy = SchedulingStrategy.TIMER_DRIVEN, period = "1 min")

您必须获取 NiFi 的源代码并将此注释添加到 GenerateFlowFile，然后重建标准 NAR 并将其部署到您的 NiFi 实例。