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

Flink CDC怎么能保证多个实例不会重复读书数据同一份binlog呢?

Flink CDC去读取binlog的数据到应用程序的时候,如果我的服务是部署多个实例的话怎么能保证多个实例不会重复读书数据同一份binlog呢?

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

Flink CDC中postgrecdc2.4.1 从指定时间戳同步数据?

Flink CDC中postgrecdc2.4.1 从指定时间戳同步数据? properties.setProperty("startup.mode","timestamp"); properties.setProperty("startup.timestamp-millis","1626169100000L"); 这样配置没有生效,正确的要如何配置啊

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

Flink CDC一个场景中需要关联十几张表并聚合,每次变更都会更新到Kafka很多数据?

Flink CDC一个场景中需要关联十几张表并聚合,我现在使用了upsertkafaka将这个大融合切成多个,但是现在问题是这样每个新任务基于上次的upsert Kafka数据量非常大,每次变更都会更新到Kafka很多数据?有没有更好的方式比如结合ice格式的流融合?es8 table connector pls不想走中转感觉走upsertKafka会变慢?

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

flink cdc 能从kafka消费数据 写到doris吗?

flink cdc 能从kafka消费数据 写到doris吗?

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

使用Flink CDC同步获取oracle11g的数据,初始化的时候有将表数据获取到,这怎么排查?

使用Flink CDC同步获取oracle11g的数据,初始化的时候有将表数据获取到,但是后面表数据变化了cdc没有获取到变化的数据,也没有报错啥的,这怎么排查?

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

flink cdc 从timestamp起,过了好久才能读到数据 找时间点的时间比较长?

flink cdc 从timestamp起,过了好久才能读到数据这个是因为需要把binlog都读一遍找到对应的时间点,找时间点的时间比较长??

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

Flink CDC只监听一个字段 其他字段数据可以拿到吗?

Flink CDC只监听一个字段 其他字段数据可以拿到吗?

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

Flink CDC进行多表的数据 全量+增量 同步,报错日志如下?

Flink CDC进行多表的数据 全量+增量 同步,测试发现表数量为23个时还能正常运行(有部分任务失败会自动重启成功),在往上(比如24,25,26张表)就不能成功了(有部分任务失败且自动重启也不成功)。报错日志如下。我提交任务的运行语句如下.:./bin/flink run-application --target kubernetes-application -Dkubernetes.cl....

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

flink cdc 自定义反序列化器,获取的数据是这样的,这种应该怎么处理?

flink cdc 自定义反序列化器,获取的数据是这样的,这种应该怎么处理?

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

大数据计算MaxCompute申请理由我填Flink CDC数据写入可以么?请问需要多久通过呢?

大数据计算MaxCompute申请理由我填Flink CDC数据写入可以么?请问需要多久通过呢?

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

产品推荐

实时计算 Flink

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

+关注