>我尝试了建议的解决方案,通过使用"UpdateAttribute"处理器来消除时间戳格式转换错误,即 ConvertJSONtoSQL-> UpdateAttribute--> PutSQL
在更新属性我使用
Property Value
--------------- ------------------------
sql.args.4.value -> ${sql.args.4.original:format("yyyy-MM-dd HH:mm:ss")}
日志:
sql.args.4.value 的值为 '',无法转换为 时间戳位于 org.apache.nifi.processor.standard.PutSQL.setParameters(PutSQL.java:690( 在
在不使用 UpdateAttribute 的情况下,我还尝试了直接 ConvertJSONtoSQL-> PutSQL。日志在引号"Aug 14 2017 10:17:00 EDT"中显示日期时间值相同的错误,即当我们使用 UpdateAttribute 时,它只是删除值并放置空引号,但错误没有解决。
注意:MySQL表具有这些列的日期时间数据类型,不确定为什么它通过尝试转换为时间戳而出错。我还在本地主机上的源和目标表中尝试了时间戳数据类型,但没有运气!
我找到了问题的答案
sql.args.n.value -> ${sql.args.n.value:format("yyyy-MM-dd HH:mm:ss.SSS")}
.