binlog source-阿里云

问答 2024-07-24 来自：开发者社区

Flink有没有什么参数可以设置mysql作为source的 binlog的保存时长？

问答 2024-07-03 来自：开发者社区

同一个Flink任务能订阅多张Hologres的Binlog作为Source不？

问答 2024-01-17 来自：开发者社区

Flink sql 里面非binlog Source表，可以设置轮询时间吗？

Flink sql 里面非binlog Source表，可以设置轮询时间吗？想着从hologre里面的A表，间隔两分钟，使用flinksql加工下，再存入hologres的B表，定时调度时间间隔最小5分钟，想把时间间隔缩小到1-2分钟。比如想做出一个召回集，给用户做推荐用；最初想着，间隔1分钟差不多；如果无限流读binlog相当于实时，这样的话，holo的B表的读写性能，我不确定会不会影响。

文章 2024-01-02 来自：开发者社区

Flink CDC 2.2.1 版本不支持通过 source 指定 binlog 或者 timestamp 的方式来做增量同步

Flink CDC 2.2.1 版本不支持通过 source 指定 binlog 或者 timestamp 的方式来做增量同步。在 Flink CDC 2.2.1 版本中，增量同步是基于数据库的 binlog 日志来实现的，而不是通过指定具体的 binlog 文件或者时间戳。然而，Flink CDC 2.2.1 版本支持在执行 checkpoint 时...

问答 2023-12-19 来自：开发者社区

Flink CDC增量source 并行度1，导致消费不到binlog，这个有没好的优化方案？

Flink CDC增量source 并行度1，导致消费不到binlog，导致延迟。这个有没好的优化方案？

问答 2023-05-23 来自：开发者社区

Flink CDC中作业重启后，source一直卡住，不读取binlog？2.1.1

问答 2022-11-13 来自：开发者社区

flink-cdc 在抽取mysql binlog，运行一段时间 source 就报java.uti

flink-cdc 在抽取mysql binlog，运行一段时间 source 就报java.util.concurrent.CompletionException: org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException: Could ...

问答 2022-07-29 来自：开发者社区

为啥我在flink里面source是hologres binlog，参数binlogStartUpM

为啥我在flink里面source是hologres binlog，参数binlogStartUpMode设置为initial，sink到rds，在全量消费阶段每次都是3分钟10000条一批，是hologres cdc source的限制吗？

问答 2022-01-19 来自：开发者社区

怎么判断 source 是否进入了 binlog 读取阶段？