问答 2023-05-30 来自:开发者社区

大佬,问下Flink CDC中现在增量读取mysql数据,如果有新增的表想要全量读取,有哪几种方式?

问题1:大佬,问下Flink CDC中现在增量读取mysql数据,如果有新增的表想要全量读取,有哪几种方式呀 ? 问题2:这个参数需要改吗,我看官网没写这个参数,我现在是latest(): .startupOptions(StartupOptions.latest())

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

Flink CDC oracle cdc 拉增量数据,跑一段时间后发现oracle 连接数一直涨,?

Flink CDC oracle cdc 拉增量数据,跑一段时间后发现oracle 连接数一直涨,有大佬遇到过这个问题吗?

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

Flink CDC Oracle有木有什么比较好的实时同步数据的方式啊?

Flink CDC Oracle有木有什么比较好的实时同步数据的方式啊?

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

Flink CDC中千万数据的mysql 订单表和 10万数据的商品表 用 flinksql同步到?

问题1:Flink CDC中千万数据的mysql 订单表和 10万数据的商品表 用 flinksql同步到 一个大宽表的时候taskheap内存占用越来越多 同步到 几十万数据的时候内存就占满了。又遇到过的吗? 问题2: INSERT INTO p_enriched_order SELECT o.,p. FROM p_code_order AS o LEFT JOIN p_product AS ....

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

请教一下,Flink CDC中debezium MySQL可以不同步初始化数据吗?实现类似Postg

请教一下,Flink CDC中debezium MySQL可以不同步初始化数据吗?实现类似PostgreSQL snapshot.mode=never的效果?

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

各位老哥 Flink CDC中你们同步入湖的时候 遇到delete 的数据怎么搞的呢?我这边是导入

各位老哥 Flink CDC中你们同步入湖的时候 遇到delete 的数据怎么搞的呢?我这边是导入kafka 在sink下游,所以需要delete数据是不是只能先insert ,后 delete啊

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

大佬 flink cdc 读取MySQL数据写入Kafka,里面的金额字段数据和MySQL的不一致?

大佬 flink cdc 读取MySQL数据写入Kafka,里面的金额字段(MySQL decemial()类型)数据和MySQL的不一致,这个该如何解决? debezium的参数配置

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

现在开源的flink和flink cdc支持flinksql的方式同步整个库的数据了么 ?

现在开源的flink和flink cdc支持flinksql的方式同步整个库的数据了么 ? 这个可以去提request ,我对整库同步比较感兴趣

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

大佬有遇到过 flink cdc 同步数据 初始化同步数据背压 到时checkpoint失败?数据

问题1:大佬有遇到过 flink cdc 同步数据 初始化同步数据背压 到时checkpoint失败?数据同步不过来的问题么?是的,倒是有个这个命令,一时半会 没想起来 问题2:您设置多长呢 我是 cdc中有udf 需要调用接口 初始化时候就反压 然后 checkpoint 无法成功,数据同步不过来, cdc 中有些比如一批一批 或者速率慢点的配置么,可以慢点

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

Flink CDC中那位老师遇到以下写法,数据可以正常写到hdfs, 但是表和库在hive看不到,?

Flink CDC中那位老师遇到以下写法,数据可以正常写到hdfs, 但是表和库在hive看不到,是由于HadoopCatalog类型 元数据没有托管到元数据服务的原因吗?:// 通过catalog判断表是否存在,不存在就创建,存在就加载 Table table = catalog.tableExists(tableIdentifier)? catalog.loadTable(tableIden....

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

产品推荐

实时计算 Flink

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

+关注