flinkcdc的数据默认保存时间是多少,我有部分数据关联不上,但是数据库中存在?

flinkcdc的数据默认保存时间是多少,我有部分数据关联不上,但是数据库中存在?

展开
收起
真的很搞笑 2023-09-20 13:03:15 89 分享 版权
1 条回答
写回答
取消 提交回答
  • Flink CDC 默认情况下会将数据保存在 Kafka 中,Kafka 中数据的保留时间取决于 Kafka 的配置。

    如果数据库中存在数据,但是 Flink 端没有数据,那么可能有以下原因:

    数据库中的数据更新时间比 Flink 端的 offset 更晚。
    Flink 端对数据库中的表执行了 ALTER 操作。
    Flink 端对数据库中的表执行了 DROP 操作。
    您可以通过以下方式排查问题:

    检查 Kafka 中的 offset。
    检查 Flink 端的配置。
    检查 Flink 端的任务日志。
    如果您仍然无法找到问题,您可以提交 issue 给 Apache Flink 社区,我们会尽快帮助您解决问题。

    2023-10-13 10:39:29
    赞同 展开评论

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

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