各位老师 弄了Flink CDC1.16.2 的 个jdbc 插入 ck 但是 ?

各位老师 弄了Flink CDC1.16.2 的 个jdbc 插入 ck 但是 decima 和 timestamp 过不去 ?image.png

展开
收起
真的很搞笑 2023-08-02 09:09:27 99 分享 版权
2 条回答
写回答
取消 提交回答
  • 北京阿里云ACE会长

    根据你提供的信息,问题似乎是由于 Flink CDC 将 Decima 和 Timestamp 数据类型写入 ClickHouse 时缺少精度范围设置引起的。这是由于 ClickHouse 对于 Decima 类型需要指定精度范围。

    要解决这个问题,你需要在 Flink CDC 的表定义中为 Decima 和 Timestamp 列指定精度范围。在你的 CREATE TABLE 语句中,确保为这些列提供合适的精度设置。

    2023-08-03 22:39:13
    赞同 展开评论
  • id 类型换成decimal(20,0),此回答整理自钉群“Flink CDC 社区”

    2023-08-02 09:13:37
    赞同 展开评论

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

还有其他疑问?
咨询AI助理