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

Flink CDC中在同一条记录更新的时候能否正常同步到sink库中, 没有被update?

Flink CDC中在同一条记录更新的时候能否正常同步到sink库中, 我oracle目标库的记录只有insert, 没有被update?

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

Flink CDC在main现成中是相等的 到了sink线程中就 改变对象了 为什么?

Flink CDC在main现成中是相等的 到了sink线程中就 改变对象了 为什么?

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

Flink CDC我这里只提供一个链接 为什么通过SINK可以打印出来多次 而且地址不一样?

Flink CDC我这里只提供一个链接 为什么通过SINK可以打印出来多次 而且地址不一样,又不是多线程 这是什么技术?

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

Flink CDC读取kafka中的订单和订单明细数据,同步到sink表后,这一般是什么问题啊?

Flink CDC读取kafka中的订单和订单明细数据,同步到sink表后,sink表的数据数量一直跳来跳去,一会几百条一会变成几十条,这一般是什么问题啊?感觉总是最后一次数据【新产生的一小部分流数据】,会把sink表中所有历史数据都清空掉用的mysql: CREATE TABLE sink_sale_order_detail_rt( order_item_id bigin...

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

Flink CDC多表 SINK 要怎么写 JDBCSINK 都是批量的固定SQL语句的?

Flink CDC多表 SINK 要怎么写 JDBCSINK 都是批量的固定SQL语句的? 要丢掉批量处理吗?

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

Flink CDC 在经过process过程后能保证到sink程序时数据是有序的吗?

Flink CDC 在经过process过程后能保证到sink程序时数据是有序的吗?

问答 2023-09-19 来自:开发者社区

Flink CDC中sink如果异常了 ,如何处理? 比如kafka宕机。数据会丢吗?

Flink CDC中sink如果异常了 ,如何处理? 比如kafka宕机。数据会丢吗?

问答 2023-09-19 来自:开发者社区

Flink CDC两台服务器传输数据,在sink端部署kafka接收数据,是否可行?

问题1:Flink CDC两台服务器传输数据,相互间无法访问对方的数据库,但服务器ip可以ping通,无法使用flink sql模式同步如果我在source端使用flink cdc捕获数据,在sink端部署kafka接收数据,是否可行?类似于这种模式?问题2:采用这种模式?source端使用debezium解析日志,传输到kafka中,sink使用flink接收数据?

问答 2023-09-19 来自:开发者社区

Flink CDC中mysql几百张表数据同步,sink端需要每张表单独操作吗?

"Flink CDC中mysql几百张表数据同步,sink端需要每张表单独操作吗?"

问答 2023-09-13 来自:开发者社区

Flink CDC这个第六步一定要写kafka吗? 直接写sink库不写kakfa不行吗?

Flink CDC这个第六步一定要写kafka吗? 直接写sink库不写kakfa不行吗? 另外如果flink中断了, 不是有checkpoint吗? checkpoint不存储上一次的scn吗? 为何要依赖kafka?

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

产品推荐

阿里云实时计算Flink

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

+关注