问答 2025-01-08 来自:开发者社区

flink cdc实时同步oracle数据库到kafka报错

flink cdc实时同步oracle数据库到kafka,我自己新建的测试表可以正常同步存量和增量数据,用另一张千万级别数据的表直接启动报错Caused by: java.io.IOException: io.debezium.DebeziumException: The db history topic or its content is fully or partially missing.....

文章 2024-05-23 来自:开发者社区

实时计算 Flink版产品使用合集之数据库中有新增索引,同步任务没有报错,索引的变动是否有影响

问题一:Flink sql将数组炸开,实现hive的explode函数的效果,还有什么其他好的方式? Flink sql将数组炸开,实现hive的explode函数的效果,除了用cross join的方式以外,还有什么其他好的方式? 参考答案: UNNEST。 关于本问题的更多回答可点击进行查看: https://d...

实时计算 Flink版产品使用合集之数据库中有新增索引,同步任务没有报错,索引的变动是否有影响
问答 2024-05-20 来自:开发者社区

Flink CDC里我这边使用的是cdc3.0版本 发现sqlserver数据库新增字段后作业报错?

Flink CDC里我这边使用的是cdc3.0版本 发现sqlserver数据库新增字段后作业就会报错是什么原因呀 ? 之前的版本不会。我这边提交不了 没有账号的 申请被拒绝了。

问答 2024-04-15 来自:开发者社区

flink cdc3.0 MySQL入doris ,两个数据库表结构一致,为什么报错?

flink cdc3.0 MySQL入doris ,两个数据库表结构一致,为什么报错Column size does not match the data size 列大小不匹配呢?报错也没有具体的列

问答 2024-02-06 来自:开发者社区

flinkcdc3.0通过flink-sql读取oracle19c数据库A表,为啥会报错?

我的环境是:flinkcdc3.0通过flink-sql读取oracle19c数据库A表数据到doris2.0的A表里;数据源oracle里A字段删除或修改,想同时目标doris修改对应的表和字段;引入是 flink-sql-connector-oracle-cdc-3.0包:写的flink-sql如下:今天试了报错:为啥报错啊?

问答 2023-12-29 来自:开发者社区

flink-cdc2.4.0监听Oracle数据库,监听表发生表结构变更报错挂掉,有解决方案吗?

flink-cdc2.4.0监听Oracle数据库,监听表发生表结构变更报错挂掉, mysql在这一块倒是支持表结构变更不受影响继续监听,oracle是还没支持还是有解决方法?用的是java集成cdc,构造数据源是使用DataStream Source。现在3.0.0会支持吗?

问答 2023-12-20 来自:开发者社区

在Flink我们现在数据库中有新增索引,但是同步任务没有报错,所以可以知道索引这边的变动的影响吗?

在Flink我们现在数据库中有新增索引,但是同步任务没有报错,所以可以知道索引这边的变动的影响吗?

问答 2023-11-22 来自:开发者社区

Flink CDC中mysql cdc 为什么没响应 而且为什么数据库链接信息报错了也没响应 ?

Flink CDC中mysql cdc 为什么没响应 而且为什么数据库链接信息报错了也没响应 ?

问答 2023-09-20 来自:开发者社区

Flink CDC数据库名有特殊字符 + 然后程序报错了 进行了转义没效果?

Flink CDC数据库名有特殊字符 + 然后程序报错了 用没有+的数据库是可以订阅的进行了转义没效果?BS3000\+_003_2016

问答 2023-09-19 来自:开发者社区

Flink CDC数据库名称里面有 +号 报错 怎么让+号可以用?

Flink CDC数据库名称里面有 +号 报错 due to error reading tables: “+”附近有语法错误。怎么让+号可以用?

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

实时计算 Flink

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

+关注