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

大佬们,Flink CDC中往doris写数据每次都返回-1,数据写不进去大佬有遇到过吗,可以读但?

大佬们,Flink CDC中往doris写数据每次都返回-1,数据写不进去大佬有遇到过吗,可以读但是写不了。也不报错,8030也没日志?就返回一个-1image.png

展开
收起
真的很搞笑 2023-08-02 09:15:34 275 0
2 条回答
写回答
取消 提交回答
  • 北京阿里云ACE会长

    在 Flink CDC 中将数据写入 Doris(以前称为Apache Doris或Palo)时返回-1可能有多个原因。以下是一些常见的问题和可能的解决方法:

    检查 Doris 连接配置:确保您在 Flink CDC 中正确配置了连接到 Doris 的相关参数,例如主机名、端口、用户名和密码。请确保这些配置与 Doris 集群的实际配置匹配,并且连接参数没有错误。

    验证表和字段映射:确保在将数据写入 Doris 之前,您已正确映射 Flink CDC 中的数据字段与 Doris 表的字段。请检查表和字段的名称、类型和顺序是否匹配。任何不匹配的映射都可能导致写入失败。

    检查数据格式和类型:确保将要写入 Doris 的数据格式和类型与 Doris 表中定义的列兼容。例如,如果一个列在 Doris 表中定义为整数类型,但您尝试写入一个字符串,可能会导致写入失败。

    查看 Doris 日志:在 Doris 集群上查看日志文件,特别是 Doris 服务节点的日志文件,以获取更多关于写入失败的详细信息。日志文件中可能会提供有关错误、异常或写入过程中发生的问题的线索。

    检查 Doris 表的状态:确保目标 Doris 表处于正确的状态,并且没有被锁定或处于只读模式。某些情况下,如果表处于只读或锁定状态,写入操作可能会失败。

    验证 Doris 版本兼容性:确保您使用的 Flink CDC 版本与所连接的 Doris 版本兼容。某些版本之间的不兼容性可能导致写入失败。请检查 Flink CDC 和 Doris 的文档或与特定版本相关的问题跟踪,以查看是否存在已知的兼容性问题。

    2023-08-03 22:06:42
    赞同 展开评论 打赏
  • 你这是table-api写进去的吗,最好sql测试下,此回答整理自钉群“Flink CDC 社区”

    2023-08-02 09:20:54
    赞同 展开评论 打赏

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

相关产品

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

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