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

Flink CDC中代码是这样的,然后跑起来,控制台一直在打日志却一直没有写入数据,什么原因?

Flink CDC中代码是这样的,然后跑起来,控制台一直在打日志,但是我想写入的表里my_user_table_copy却一直没有写入数据,什么原因?
350acc86cf0116467b6e96a28128f387.png
38076337c0602715410372abceac5d51.png

展开
收起
十一0204 2023-08-09 08:39:56 129 0
1 条回答
写回答
取消 提交回答
  • 北京阿里云ACE会长

    有几个可能导致没有数据写入的原因:

    表结构不匹配:确保目标表(my_user_table_copy)的结构与源表(my_user_table)的结构相匹配。检查表的列名、数据类型和主键定义是否一致。

    数据源为空:在执行插入语句之前,确保源表(my_user_table)中存在数据。如果源表中没有数据,插入操作将不会写入任何内容。

    数据写入失败:检查连接器(JDBC)的配置是否正确。确保连接器的驱动程序类、连接 URL、用户名和密码等参数正确设置。如果连接器配置有误,数据写入操作可能会失败。

    错误处理和日志:在代码中,注释掉了查询并打印返回结果的代码(tableResult2.print())。这意味着你无法看到插入操作的结果和错误信息。建议取消注释该行代码,这样你就能够看到执行插入操作的结果和可能的错误信息。

    2023-08-13 17:09:28
    赞同 展开评论 打赏

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

相关产品

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

    更多
    PostgresChina2018_赖思超_PostgreSQL10_hash索引的WAL日志修改版final 立即下载
    Kubernetes下日志实时采集、存储与计算实践 立即下载
    日志数据采集与分析对接 立即下载