我有以下记录:
{"id": 2, "time": "2020-03-03T13:26:41.298"}
如果我想用apache flink读取此记录,将显示以下错误消息:
java.time.format.DateTimeParseException: Text '2020-03-03T13:26:41.298' could not be parsed at index 23
piah890a1#
根据 DataTypes.TIMESTAMP(p) 的实现,它使用此格式化程序因此,您需要添加一个'z'作为时间戳的后缀(或更改日期类型)2020-03-03t13:26:41.298应改为2020-03-03t13:26:41.298z
DataTypes.TIMESTAMP(p)
1条答案
按热度按时间piah890a1#
根据
DataTypes.TIMESTAMP(p)
的实现,它使用此格式化程序因此,您需要添加一个'z'作为时间戳的后缀(或更改日期类型)
2020-03-03t13:26:41.298应改为2020-03-03t13:26:41.298z