NiFi数据流CRON调度及单次执行自动停止问题求助

一、手动启动后重复执行的解决方法 #

• GetFile处理器核心配置调整：
  1. 将Keep Source File设为false，文件被读取后自动删除，避免重复扫描触发
  2. 若处理固定文件，在File Filter中指定具体文件名，防止扫描到目录内其他文件
  3. 右键处理器→调度→将调度策略改为Run Once，启动后仅执行一次即停止
• 额外控制方案：可在GetFile与PutDatabaseRecord之间添加UpdateAttribute标记文件处理状态，搭配StopProcessor控制器服务，完成文件写入后自动停止GetFile处理器

二、CRON调度无输出的排查与解决 #

1. 时区匹配问题 #

NiFi默认使用UTC时区，你设置的0 30 1 1/1 * ? *对应UTC时间1:30，转换为CST（UTC+8）是当天9:30，与预期的1:30不符。解决方式二选一：

• 修改CRON表达式为UTC时区对应值：0 30 17 ? * * *（对应CST次日1:30）
• 修改NiFi全局时区：编辑nifi.properties文件，将nifi.scheduling.timezone设为Asia/Shanghai，之后直接使用CST时间的CRON表达式0 30 1 1/1 * ? *即可

2. 处理器调度配置检查 #

• 确保两个处理器的调度策略均设为CRON Driven，且正确填入目标表达式
• CRON驱动模式下，Run Schedule字段需留空，不要填写任何值
• 集群环境下，确认Execution Node设置符合业务需求（如指定节点或所有节点）

3. 文件与权限验证 #

• 检查GetFile的Input Directory路径是否正确，NiFi进程是否拥有该目录的读取权限
• 确认调度时间点时，目标CSV文件已存在于输入目录，且符合File Filter、Minimum File Size等过滤规则

4. 日志排查 #

查看NiFi安装目录下的nifi-app.log，搜索对应处理器的日志条目，排查是否存在数据库连接失败、文件读取异常、CRON表达式解析错误等问题

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