开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

Flink CDC里建了一张upsert-kafka的flink表,但是数据为空怎么办?

Flink CDC里建了一张upsert-kafka的flink表,但是数据为空。topic里面是有数据的。这个现象正常么?ba462095e91b21b91beebf68259356a4.png878c104e4141c077a2d737affde6abf5.pngtopic里有两条数据,只不过数据内容一样c2cc01e7a63c95863d84beb3efbc27db.png486ec61680c006d39bbb9242643da5fa.png3299bdfc534fd900c42989dc208fb8b6.png

展开
收起
小小鹿鹿鹿 2024-01-18 00:30:41 98 0
2 条回答
写回答
取消 提交回答
  • 面对过去,不要迷离;面对未来,不必彷徨;活在今天,你只要把自己完全展示给别人看。

    如果Flink CDC里建了一张upsert-kafka的flink表,但是数据为空,可以尝试以下方法解决:

    1. 检查Kafka主题是否正确配置,确保生产者和消费者都正确连接到Kafka集群。
    2. 检查Flink CDC的配置,确保源表和目标表的连接信息、Kafka配置等参数正确。
    3. 检查Flink CDC的运行状态,查看是否有错误或异常信息。如果有错误信息,可以根据错误提示进行排查。
    4. 检查Kafka中的数据是否已经写入到Flink表中。可以使用Kafka消费者工具或者Flink SQL查询来验证数据是否存在。
    5. 如果数据确实存在,但仍然为空,可能是由于Flink CDC的延迟或者处理能力不足导致的。可以考虑增加Flink CDC的处理能力,例如增加并行度、调整任务分配策略等。
    6. 如果以上方法都无法解决问题,建议查阅Flink CDC的官方文档或者寻求社区支持,以获取更详细的解决方案。
    2024-01-19 15:38:56
    赞同 展开评论 打赏
  • 查不出来不正常,但是插入数据成功了,能被消费到。虽然格式看起来有一点不规范吧。此回答来自钉群Flink CDC 社区。

    2024-01-18 10:50:09
    赞同 展开评论 打赏

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

相关产品

  • 实时计算 Flink版
  • 相关电子书

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