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

Flink多个表的同步顺序 是按照binlog顺序执行的么?有个表的同步失败了会影响后续执行吗?

Flink多个表的同步顺序 是按照binlog顺序执行的么?有个表的同步失败了 会影响后续执行吗?

文章 2024-07-16 来自:开发者社区

实时计算 Flink版产品使用问题之如何保证持续稳定地读取binlog

问题一:Flink CDC里有人了解mysql binlog生成机制吗 ? Flink CDC里有人了解mysql binlog生成机制吗 ? flink cdc为什么有时候能读到binlog 有时候不能啊? 参考答案: MySQL Binlog(二进制日志)是MySQL数据库用于记录所有更改数据的逻辑日志,包括数据的增删改操作。MySQL通过启用二进...

实时计算 Flink版产品使用问题之如何保证持续稳定地读取binlog
文章 2024-07-16 来自:开发者社区

实时计算 Flink版产品使用问题之如何指定从特定的binlog位置或最新的binlog位置开始读取数据

问题一:Flink CDC里flinkcdc3.0启动同步任务,还需要添加什么环境吗? Flink CDC里flinkcdc3.0启动同步任务,还需要添加什么环境吗?exec "$JAVA_RUN" -classpath "$CLASSPATH" "${LOG_SETTINGS[@]}" com.ververica.cdc.cli.CliFrontend "$@" ...

实时计算 Flink版产品使用问题之如何指定从特定的binlog位置或最新的binlog位置开始读取数据
文章 2024-07-16 来自:开发者社区

实时计算 Flink版产品使用问题之如何查看当前消费的binlog位置

问题一:Flink CDC里dlink 整库同步 支持字段变更吗 ? Flink CDC里dlink 整库同步 支持字段变更吗 ?flink 任务 运行过程中,source 表 添加了一个字段,能获取到,然后同步到sink表中是吧? 参考答案: 支持,但是支持的sink数据库不多,详细看官网。 关于本问题的更多回答可点击进行...

实时计算 Flink版产品使用问题之如何查看当前消费的binlog位置
文章 2024-07-16 来自:开发者社区

实时计算 Flink版产品使用问题之如何启动多个jar包来监听同一个数据库的binlog,并针对不同的业务进行处理

问题一:flink cdc 3.0对切片key是字符串不能进行切分吗? flink cdc 3.0对切片key是字符串不能进行切分吗? 参考答案: source是复用原来的,你这个错误不是切分key...

实时计算 Flink版产品使用问题之如何启动多个jar包来监听同一个数据库的binlog,并针对不同的业务进行处理
问答 2024-07-10 来自:开发者社区

麻烦咨询一下Flink,cdc采集binlog,有办法监控采集的offset吗?

麻烦咨询一下Flink,cdc采集binlog,有办法监控采集的offset吗

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

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

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

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

Flink CDC 读取MySQL binlog 会偶现这个错误,有谁知道是什么引起的嘛?

Flink CDC 读取MySQL binlog 会偶现这个错误,有谁知道是什么引起的嘛?

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

对于Flink CDC,怎么在解析binlog的时候判断是datetime类型,然后减8小时给它?

对于Flink CDC,怎么在解析binlog的时候判断是datetime类型,然后减8小时给它?

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

在Flink CDC中需要查看任务对应binlog-position请问这个监控指标在哪查看?

在Flink CDC中binlog 推送kafka连接器中断,怀疑是binlog被清除了,需要查看任务对应binlog-position请问这个监控指标在哪查看,flink-web-ui里没看见?

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