Apache NiFi集群中QueryDatabaseTable无法选择全节点执行的求助

QueryDatabaseTable处理器本身设计就不支持"全节点"执行模式，这是因为它需要维护查询的状态（比如记录上次查询的最大偏移值，如ID、时间戳），如果多个节点同时执行会导致重复抓取数据、状态冲突，所以NiFi直接禁用了该选项，和删除重建处理器无关。而同数据流的PutDatabaseRecord是无状态的写入操作，因此支持全节点并行执行。

如果想要实现类似集群并行查询的效果，可以参考以下方案：

• 使用QueryDatabaseTableRecord处理器替代：该处理器支持配置数据分片规则（比如按ID范围、日期分区），让不同节点查询不同的数据段，既实现并行处理，又避免重复抓取。
• 保留QueryDatabaseTable主节点执行，后续分发数据：让QueryDatabaseTable在主节点完成查询后，通过DistributeLoad或CloneRecord处理器将数据分发给集群其他节点，后续的PutDatabaseRecord仍用全节点模式执行，兼顾查询一致性与集群处理能力。
• 若业务允许无状态查询：可以禁用QueryDatabaseTable的状态跟踪（取消配置"Maximum Value Columns"），但这种情况下每次都会全量查询数据，可能导致重复处理，需结合业务场景评估风险。

内容的提问来源于stack exchange，提问作者covfefe