开发者社区> 问答> 正文

Flink报错:Invalid data type of time field for wat...

已解决

Flink报错:Invalid data type of time field for watermark definition. The field must be of type TIMESTAMP(p) or TIMESTAMP_LTZ(p), the supported precision 'p' is from 0 to 3, but the time field type is TIMESTAMP(6)

展开
收起
提个问题 2024-06-14 18:03:54 72 0
1 条回答
写回答
取消 提交回答
  • 开发者社区问答官方账号
    官方回答
    采纳回答
    【报错详情】
    Caused by: org.apache.flink.table.api.ValidationException: Invalid data type of time field for watermark definition. The field must be of type TIMESTAMP(p) or TIMESTAMP_LTZ(p), the supported precision 'p' is from 0 to 3, but the time field type is TIMESTAMP(6) at org.apache.flink.table.catalog.DefaultSchemaResolver.validateTimeColumn(DefaultSchemaResolver.java:263) at org.apache.flink.table.catalog.DefaultSchemaResolver.resolveWatermarkSpecs(DefaultSchemaResolver.java:218)
    【报错原因】
    watermark接收的字段,精度超过了TIMESTAMP(3)。
    【解决方案】
    将字段类型修改为TIMESTAMP(3)精度以内,或使用TO_TIMESTAMP函数将该字段类型进行转换。
    2024-06-14 18:03:56
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载