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

Flink CDC中source、sink对flink来说对一个算子确实没有内外部,同步了多少的量?

Flink CDC中source、sink对flink来说对一个算子确实没有内外部,我想了解下能不能获取外部系统-一个算子的source有多少条数呢,比如mysqlcdc同步mysql的数据,同步了多少的量?

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

flink cdc mysql 表数据 sink 到elasticsearch

当sink到elasticsearch 时,可以指定es的指定字段吗?比如es索引有 10个字段,我只需要插入或者更新 其中5个字段,当更新时,不会影响其他5个字段的原来的值!

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

Flink CDC单表发现修改并行度后source和sink端都是1,是只能为1还是可以修改?

Flink CDC单表发现修改并行度后source和sink端都是1,是只能为1还是可以修改?

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

Flink CDC中sink写mysql,表既有主键又有唯一键,不是幂等的,遇到过这种吗?

Flink CDC中sink写mysql,表既有主键又有唯一键,不是幂等的,只能用精确一次语义,大佬遇到过这种吗?

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

Flink CDC写sink到doris遇到问题,写不进去。这个,flink官网这块的demo多不?

Flink CDC写sink到doris遇到问题,写不进去。这个,flink官网这块的demo多不,我找了下没看到?1.17版本

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

flink mongodb cdc读取数据后支持下游sink创建表吗?

flink mongodb cdc读取数据后支持下游sink创建表吗?

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

Flink CDC可以sink到hbase吗?

Flink CDC可以sink到hbase吗?

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

Flink CDC sink到mongodb需要什么包?

Flink CDC sink到mongodb需要什么包?

问答 2023-11-30 来自:开发者社区

Flink CDC支持sink到多分区的kafka ,还能保持有序吗?

Flink CDC支持sink到多分区的kafka ,还能保持有序吗?

问答 2023-11-22 来自:开发者社区

Flink CDC中SQLServer多库同名表写入到一张sink表中,有什么思路吗?

Flink CDC中SQLServer多库同名表写入到一张sink表中,我有个思路是创建n个source,最后把n个source union all到一起insert到sink表中,但是问题1️:这样会创建多个连接,问题2️:后续SQLServer增删改数据时,sink端无法同步删除,只能同步增改。大佬有什么思路吗

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

产品推荐

阿里云实时计算Flink

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

+关注