【发布时间】：2021-01-21 04:18:52
【问题描述】：
我正在探索 nifi，因为我已经创建了具有处理器数量的处理器组，这些处理器组基本上从 Oracle DB 中选择数据并插入到 mongoDB。流程按预期工作。
流量是QueryDatabaseTable -> SplitAvro -> ConvertAvorToJson -> PutMongoRecord
在QueryDatabaseTable 我有自定义查询select * from employee，它给了我100 条记录并将这100 条记录插入到mongoDB 中。但是这里的问题是QueryDatabaseTable 被一次又一次地调用，所以结果相同的 100 条记录被一次又一次地添加到 mongoDB 中。有没有办法阻止这种重复执行？提前致谢。
更新：我正在使用Nifi 1.9.2
PFB QueryDatabaseTable 设置标签下方
属性
更新 2：配置
【问题讨论】：
-
请显示您为 QueryDatabaseTable 设置的参数。
-
在默认值的情况下将计时器设置为不为零或使用 cron 更改调度。
-
@daggett 我已经附加了 QueryDatabaseTable 的配置
-
@Lamanus 是的，我已将
Run Schedule更改为非 zore 值及其工作
标签： apache-nifi