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

为什么flinkcdc中sql确实执行成功了,但是job执行未成功,kibana里面也没有找到数据?

为什么flinkcdc中sql确实执行成功了,但是job执行未成功,kibana里面也没有找到数据?用的是官方快速上手教程的mysql\pg例子,docker启动的mysql和pgsql。54ff200881306efe56e13531752a531f.png

展开
收起
十一0204 2023-07-19 17:22:35 116 0
1 条回答
写回答
取消 提交回答
  • 北京阿里云ACE会长

    在 Flink CDC 中,如果您的 SQL 执行成功但作业未成功,并且在您预期的目标系统中没有看到数据,可能是以下一些原因:

    SQL 执行成功但未提交
    如果您的 SQL 在 Flink CDC 中执行成功但未提交,可能是因为您的 SQL 在事务中执行,并且事务尚未提交。在这种情况下,Flink CDC 不会将未提交的更改写入目标系统中。您可以检查您的 SQL 是否在事务中执行,并确保在执行 SQL 之后提交事务。

    CDC 任务未正确配置
    如果您的 CDC 任务未正确配置,可能无法正确读取和写入数据。例如,您可能未正确配置 CDC 数据源或未正确设置目标系统连接。您可以检查您的 CDC 任务配置是否正确,并确保 CDC 任务能够正确地读取数据并将其写入目标系统。

    目标系统连接失败
    如果您的 CDC 任务无法连接到目标系统,可能导致无法将数据写入目标系统。例如,如果您的目标系统是 Apache Kafka,但您的 CDC 任务无法连接到 Kafka 集群,则无法将数据写入 Kafka 主题。您可以检查您的目标系统连接是否正常,并确保 CDC 任务能够正确地将数据写入目标系统。

    数据格式错误
    如果您的 CDC 任务能够正确读取数据但无法将其写入目标系统,可能是因为数据格式不正确。例如,您可能未正确指定目标系统中数据的格式或未正确设置序

    2023-07-29 20:09:33
    赞同 展开评论 打赏

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

相关电子书

更多
SQL Server 2017 立即下载
GeoMesa on Spark SQL 立即下载
原生SQL on Hadoop引擎- Apache HAWQ 2.x最新技术解密malili 立即下载