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

Flink CDC 15版本读写datahub的时候 日志打印就是这个,读不到数据。这个是什么原因?

Flink CDC 15版本读写datahub的时候 日志打印就是这个,读不到数据。别的没有错误信息,这个是什么原因?
8d0d34a7db246fe6732da4c5f398990a.png

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

    可能与序列化器的配置有关。以下是一些建议,帮助您排查问题:

    检查 Flink 的依赖和版本:确保您使用的 Flink 版本与相关依赖项(如 Kafka、DataHub 连接器)兼容,并且版本匹配。不同版本的 Flink 和相关库可能存在兼容性问题。

    检查序列化器配置:在 Flink 中,序列化器负责将数据序列化和反序列化。您可以检查 Flink 的配置文件(如 flink-conf.yaml)中的相关配置项,确保序列化器的配置正确。您可以尝试使用其他可用的序列化器,如 AvroSerializer 或 JSON 序列化器,看是否能解决问题。

    检查连接器配置:如果您使用的是 Flink 的 DataHub 连接器或其他 CDC 连接器,确保连接器的配置正确。这包括检查连接字符串、认证凭据、主题名称等。确保连接器与 DataHub 或其他数据源的版本兼容。

    检查网络连接和权限:确保 Flink 与 DataHub 或其他数据源之间的网络连接正常,并且具有正确的权限以读取数据。检查网络配置、防火墙设置和访问权限等。

    2023-08-13 20:10:59
    赞同 展开评论 打赏

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

相关产品

  • 实时计算 Flink版
  • 热门讨论

    热门文章

    相关电子书

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