NiFi 1.22.0中PutSQL处理器未执行SQL语句问题求助

问题现象 #

• 目标进程组内PutSQL组件的实例数量持续增加
• 与PutSQL连接的上游队列消息数无减少迹象
• PutSQL未执行输入的SQL语句
• 已尝试将Support Fragmented Transactions配置从False改为True，问题仍未解决

排查方向 #

1. 数据库连接池与后端状态检查 #

• 查看关联的DBCPConnectionPool组件状态，重点关注Active Connections、Idle Connections指标，确认是否存在连接耗尽、阻塞
• 登录数据库端，检查是否存在锁表、长时间未提交的事务，或数据库服务是否处于高负载、异常状态

2. 组件日志与报错排查 #

• 进入PutSQL组件详情页，查看Bulletin History和Component Log，定位是否存在SQL语法错误、权限不足、连接超时等具体报错
• 抽样检查待处理FlowFile的内容或sql.statement属性，确认是否为合法可执行的SQL语句，是否存在变量替换失败问题

3. 并发与调度配置验证 #

• 检查Process Group的Concurrent Tasks设置，避免因并发过高导致资源竞争
• 确认PutSQL的Max Concurrent Tasks配置合理，若数值过大可能引发线程阻塞
• 核对组件的Scheduling Strategy和Scheduling Period，确保调度任务正常触发

4. FlowFile路由与属性校验 #

• 验证上游组件是否将正确的FlowFile路由至PutSQL，可通过ListQueue工具查看队列中FlowFile的属性、内容
• 检查PutSQL的SQL Statement配置，确认表达式语言（EL）使用正确，变量引用无误

5. 节点资源与JVM状态排查 #

• 监控NiFi所在服务器的CPU、内存、磁盘IO使用率，排查是否因资源耗尽导致组件无法正常工作
• 查看NiFi的JGC日志，确认是否存在GC频繁、堆内存不足（OOM）等情况

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