Apache NiFi：使用UpdateRecord更新时区未生效问题

问题详情 #

• 源CSV数据：

"date_time"
"2024-07-30 19:59:04"

该时间实际时区为GMT+3，使用UpdateRecord组件配置如下规则后，无法得到预期的GMT时区时间：

Replacement Value Strategy  -> Literal Value
/new_dt                     -> ${date_time.value:toDate():toNumber():minus(3600).format("yyyy-MM-dd HH:mm:ss", "GMT")}

预期输出：

"new_dt"
"2024-07-30 16:59:04"

实际输出：时间无变化，仍为2024-07-30 19:59:04

错误原因 #

1. 时区解析缺失：toDate()方法未指定原时间的时区（GMT+3），系统默认会用本地时区或JVM默认时区解析字符串，导致生成的时间对象并非对应GMT+3的时间。
2. 时间差计算错误：GMT+3与GMT的时差为3小时，需减去3*3600=10800秒，而非原表达式中的3600秒（1小时）。

修正后的表达式 #

方案1：解析时区+调整时间戳 #

${date_time.value:toDate("yyyy-MM-dd HH:mm:ss", "GMT+3"):toNumber():minus(10800).format("yyyy-MM-dd HH:mm:ss", "GMT")}

方案2：直接转换时区（更简洁） #

无需手动计算时间差，解析时指定原时区后直接格式化为GMT即可：

${date_time.value:toDate("yyyy-MM-dd HH:mm:ss", "GMT+3"):format("yyyy-MM-dd HH:mm:ss", "GMT")}

验证效果 #

使用上述任一修正后的表达式，输出结果将符合预期：

"new_dt"
"2024-07-30 16:59:04"

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