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

使用flink-cdc消费 oracle的标带斜杠的嘛? 好像消费不了。

使用flink-cdc消费 oracle的标带斜杠的嘛? 好像消费不了。

展开
收起
小易01 2023-08-16 08:00:48 83 0
1 条回答
写回答
取消 提交回答
  • 使用 Flink CDC 消费 Oracle 数据时,如果表名或列名带有斜杠,会出现如下错误:

    java.lang.IllegalArgumentException: Illegal column name 'table_name/column_name'
    这是因为 Flink CDC 默认使用 table.column 的格式来写入数据,而 Oracle 数据库中表名和列名的组成是 schema.table.column。因此,如果表名或列名带有斜杠,就会出现这种错误。

    解决这个问题的方法是通过 cdc.table.name.format 配置来指定数据表的格式。例如,如果表名是 schema.table,列名是 column,可以使用如下配置:

    cdc.table.name.format = schema.table
    这样,Flink CDC 就会使用 schema.table.column 的格式来写入数据,就可以正常消费数据了。

    2023-09-22 11:13:05
    赞同 展开评论 打赏

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

相关产品

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

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

    相关镜像