文章 2024-08-29 来自:开发者社区

实时计算 Flink版产品使用问题之如何高效地将各分片存储并跟踪每个分片的消费位置

问题一:flink CDC中,同步任务重并没有同步mysql某张表,如果未被同步的表结构变更了怎么办? flink CDC中,同步任务重并没有同步mysql某张表,如果未被同步的表结构变更了,flinkCDC 同步任务也会报错。按理说应该不会,是不是可以做些设置呢? 参考答案: 3.0.1 修复了。 关于本问题的更多回答可点...

问答 2024-08-12 来自:开发者社区

在Flink CDC中,可以看下日志,是卡在最后一个分片了吗?

在Flink CDC中,可以看下日志,是卡在最后一个分片了吗?

问答 2024-08-07 来自:开发者社区

在Flink CDC中,这个是分片信息吗?

在Flink CDC中,这个是分片信息吗?

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

Flink batch 模式下 实现多路多分片读 有示例么 ?

Flink batch 模式下 实现多路多分片读 有示例么 ?

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

分片表添加字段 Flink CDC错 ,如何解决?

Flink CDC中,分片表添加字段报错,可以看下吗 ?

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

Flink CDC中,在支持分片独立消费的CDC binlog数据源中,如何高效地将各分片存储?

Flink CDC中,在支持分片独立消费的CDC binlog数据源中,如何高效地将各分片的offset以JSON格式或其他合适方式存储在SourceRecord的sourceOffset Map中?对于具有shardId和pos属性的CDC记录,应如何设计并更新offsetMap以跟踪每个分片的消费位置?

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

Flink CDC里对于经常水平扩展的分布式数据库,实时同步,在扩展数据库分片节点,可以直接加源吗?

Flink CDC里对于经常水平扩展的分布式数据库,实时同步,有没有好的措施 ,在扩展数据库分片节点实例时,不需要重启 直接增加一个source源的?

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

flink cdc 3.0 分库分表怎么加上分片id?

flink cdc 3.0 分库分表同步中如果每个分片表主键id会重复的话合并成ods层一张全表时怎么加上分片id? route支持吗?

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

Flink 模式下多分分片多路读 batch模式就是多分片多路复用了 这是哪里有设置么?

Flink SingleThreadMultiplexSourceReaderBase stream模式下多分分片多路读 batch模式就是多分片多路复用了 这是哪里有设置么?

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

Flink CDC batch模式就是多分片多路复用了 这是哪里有设置么?

Flink CDC SingleThreadMultiplexSourceReaderBase stream模式下多分分片多路读 batch模式就是多分片多路复用了 这是哪里有设置么?

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

产品推荐

阿里云实时计算Flink

一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。

+关注