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

Flink CDC增加时间窗口后,有办法让source源,在完成上一次的sink之后,再继续读取吗?

Flink CDC增加时间窗口后,有办法让source源,在完成上一次的sink之后,再继续读取吗?

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

使用Flink CDC的时候,sink端写入数据失败,有没有办法捕获存储起来?

使用Flink CDC的时候,sink端写入数据失败,有没有办法捕获存储起来?

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

Flink CDC现在pipeline能支持一个source端对应多个sink端吗?

Flink CDC现在pipeline能支持一个source端对应多个sink端吗,比如说mysql 同时写入到starRocks和kafka中,我目前没有找到多sink写入的例子?

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

Flink CDC中sql server cdc 不支持sink吗 ?

Flink CDC中sql server cdc 不支持sink吗 ?

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

Flink CDC里sink开启多个并行度,你是怎么保证binlog的顺序的?

Flink CDC里sink开启多个并行度,你是怎么保证binlog的顺序的?

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

Flink CDC里在这可以有设置并行度的参数么,貌似没有吧,只有sink端可以吧?

'connector' = 'mysql-cdc', 'hostname' = '{}', 'port' = '{}', 'database-name' = '{}', 'username' = '{}', 'password' = '{}', ...

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

Flink CDC里如果sink的并行度是2,其中一个sink失败了怎么保证extract ?

Flink CDC中两阶段提交是指某个sink里还是所有sink一起成功才成功,否则所有sink一起回滚吗?

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

Flink CDC中2个sink属于同一个事务还是两个独立的事务?

Flink CDC中2个sink属于同一个事务还是两个独立的事务?如果是独立的事务,重试时source会重新抽了,会不会有重复数据写入sink了?

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

Flink CDC里如果sink的并行度是2,其中一个sink失败了,怎么保证啊?

Flink CDC里如果sink的并行度是2,其中一个sink失败了,怎么保证extract once?

问答 2024-04-23 来自:开发者社区

Flink CDC有遇到输入流合并后输出到一个sink 里面去,过一会sink 里面就收不到数据吗?

Flink CDC里有遇到输入流合并后输出到一个sink 里面去,过一会sink 里面就收不到数据的情况吗?

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

产品推荐

阿里云实时计算Flink

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

+关注