问答 2023-07-26 来自:开发者社区

Flink CDC中维表数据开启缓存怎么开启?不是那个ttl吗?

Flink CDC中维表数据开启缓存怎么开启?不是那个ttl吗?我看那个ttl默认就是开启缓存的呀。

问答 2023-07-26 来自:开发者社区

Flink CDC中在获取维表数据的时候,是一次批量获取的还是一条一条获取的?

Flink CDC中在获取维表数据的时候,是一次批量获取的还是一条一条获取的?

问答 2023-07-26 来自:开发者社区

Flink CDC中debezium 捕获容器环境的oracle要等20分钟才有数据是什么原因?

Flink CDC中debezium 捕获容器环境的oracle要等20分钟才有数据是什么原因?

问答 2023-07-26 来自:开发者社区

Flink CDC中我的场景是同步Mysql数据到es中,应该怎样写才可以插入一组数据?

Flink CDC中我的场景是同步Mysql数据到es中,es索引对应的类型是一个数组,我在flink sql中创建了对应的类型 regions ARRAY>, 那insert into到 es_index应该怎样写才可以插入一组数据,我使用insert into es_index select ROW(regionId, regionName) AS regions from ... 只能...

问答 2023-07-26 来自:开发者社区

Flink CDC中捕获容器oracle的日志,为啥要二十分钟才有数据?

Flink CDC中捕获容器oracle的日志,为啥要二十分钟才有数据?

问答 2023-07-26 来自:开发者社区

Flink CDC中增量监听binlog日志同步的时候也会把全部数据都加载到内存吗?

Flink CDC中增量监听binlog日志同步的时候也会把全部数据都加载到内存吗?有没有试过?我现在还在全量同步阶段,如果单独的增量同步不存在全部加载到内存的问题的话,可不可以先用维表的方式做完全量同步。然后再全部流表,但是启动时跳过快照阶段,直接指定位点启动一个新的任务做后续更新同步。

问答 2023-07-26 来自:开发者社区

"Flink CDC中这个报错有遇到过吗?读取MySQL的数据和Kafka有什么关系?

"Flink CDC中这个报错有遇到过吗?读取MySQL的数据和Kafka有什么关系?怎么会报一个Kafka的类型问题?这张源表给的是decimal类型,但是看changelog的default 值是一个string。 "

问答 2023-07-26 来自:开发者社区

Flink CDC中当前是启动任务全量数据可以同步,增量数据不同步怎么排查?

Flink CDC中,我是flink1.17.1+mysql cdc2.4.0+mysql5.7(source端),当前是启动任务全量数据可以同步,增量数据不同步,checkpoint开启了,也没见什么异常信息。怎么排查?我这边使用的Dinky,通过SQL的方式做的,如下是SQL配置部分

问答 2023-07-26 来自:开发者社区

Flink CDC中可以拿到数据了,但是跑一段时间任务就OOM了,看了下背压很严重啊,怎么解决?

"问题1:Flink CDC中可以拿到数据了,但是跑一段时间任务就OOM了,看了下背压很严重啊,怎么解决?动态表是最细的表,通过动态表的一条数据在另外两个维表里最多只查出来一条数据。问题2:p 48 -Dyarn.application.queue=default -Dtaskmanager.numberOfTaskSlots=4 -Djobmanager.memory.process.size....

问答 2023-07-26 来自:开发者社区

Flink CDC中oracle cdc支持带我分区表的数据同步吗?主要是同步带有分区表的数据会报错

Flink CDC中oracle cdc支持带我分区表的数据同步吗?主要是同步带有分区表的数据会报topic有问题。

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

产品推荐

实时计算 Flink

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

+关注
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等