问答 2024-05-20 来自:开发者社区

Flink CDC里mysql到doris 同步 用yaml配置文件很方便 以后会增加更多数据吗?

Flink CDC里mysql到doris 同步 用yaml配置文件很方便 以后会增加更多数据源快速配置同步?今年之内能有pg到doris吗?

问答 2024-05-20 来自:开发者社区

Flink cdc=3.0 , Streaming API 为什么捕获不到新增数据?

Flink cdc=3.0 , Streaming API 通过incremental snapshot的方式采集数据,为什么配置startupOptions(StartupOptions.latest())就捕获不到新增数据呢? 我上周测还是可以捕获的。

问答 2024-05-20 来自:开发者社区

Flink CDC里使用initial模式, 转增量之后,存量数据会丢吗?

Flink CDC里我使用cdc作为flink的流表。使用initial模式, 转增量之后,存量数据会在内存里丢掉吗。 我window统计, 转增量后统计数据变少了

问答 2024-05-20 来自:开发者社区

Flink cdc里面 scan设置成true之后新创建的表插入数据会捕获不到吗?

Flink cdc里面scan.newly-added-table.enabled 设置成true之后新创建的表插入数据会捕获不到吗?

问答 2024-05-20 来自:开发者社区

Flink CDC里我们数据 在阿里的RDS 上,现在逻辑是直接SQL 读取,数量多怎么办?

Flink CDC里我们数据 在阿里的RDS 上,现在逻辑是直接SQL 读取,各种JOIN 之后在展示在BI上,如果后面数据量多的话 ,有没有好的建议。现在是想把RDS的数据同步到 DORIS 然后读DORIS 在做数据处理这个逻辑行不行?

问答 2024-05-20 来自:开发者社区

我自己测试flink cdc 读取MySQL表,通过sql client映射表后,去查询,没有数据?

我自己测试flink cdc 读取MySQL表,通过sql client映射表后,去查询,没有数据,任务直接finshed了是什么原因?但是我任务本地idea是可以跑的

问答 2024-05-20 来自:开发者社区

Flink CDC里flinksql 维表join ,主表同一条数据3s内连续变更是什么造成的?

Flink CDC里flinksql 维表join ,主表同一条数据3s内连续变更,维表字段会关联出很久以前的数据,这种是什么情况造成的呢?create table source_trade_order_test1 ( schema STRING , table STRING , action string, columns ARRAY>, ...

问答 2024-05-20 来自:开发者社区

Flink CDC里 elsaticseach 跨集群同步数据有使用 增量/全量吗?

Flink CDC里 elsaticseach 跨集群同步数据有使用 增量/全量, 使用 flink-cdc 可行吗?

问答 2024-05-19 来自:开发者社区

Flink CDC里一般如何解决CDC数据过多的问题?

Flink CDC里一般如何解决CDC数据过多的问题?

问答 2024-05-19 来自:开发者社区

Flink CDC里用的datastream,不知道为什么每次都会消费历史数据?

Flink CDC里用的datastream,不知道为什么每次都会消费历史数据?

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

产品推荐

实时计算 Flink

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

+关注
AI助理

你好,我是AI助理

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