问答 2024-08-28 来自:开发者社区

flink cdc同步一张mysql按天分表数据,能否监听到 mysql 源端的这两个操作?

flink cdc同步一张mysql按天分表数据,能否监听到 mysql 源端的这两个操作?TRUNCATE TABLE ad_account_daily_stat_finance_${date}; DROP TABLE ad_account_daily_stat_finance_${date};

文章 2024-08-19 来自:开发者社区

实时计算 Flink版产品使用问题之在处理数据流时,有些订单被监听到有些没有被监听到,是什么原因

问题一:想问下哪位对Flink 1.16支持的hdfs最高版本是多少? 想问下哪位大佬对Flink 1.16支持的hdfs最高版本是多少?目前用的hdfs3.2.4,官网也没有找到相关的说明,但是部署flink on yarn,总不成功 ...

实时计算 Flink版产品使用问题之在处理数据流时,有些订单被监听到有些没有被监听到,是什么原因
问答 2024-08-18 来自:开发者社区

flink cdc 监听 发送数据到rocketmq ,但是运行一段时间后发送失败 怎么办?

flink cdc 监听mysql binlog 发送数据到rocketmq ,但是运行一段时间后 发送失败 内存oom,有没有什么好的办法呢?

问答 2024-08-12 来自:开发者社区

在Flink CDC中,一直在监听和同步,实际上源端已经不产生数据了,这种任务就应该停止掉吧?

在Flink CDC中,那提交了一个任务后一直在监听和同步,实际上源端已经不产生数据了,这种任务就应该停止掉吧?不然一直占用着一个slot,这个有办法判断吗?

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

在Flink CDC中用3.1.1版本监听schema,出现中文乱码,这个有什么解决方案吗?

在Flink CDC中用3.1.1版本监听schema,出现中文乱码,这个有什么解决方案吗?请参考图片:

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

Flink CDC监听不到mysql数据增量变更

mysql my.cnf 中的 binlog_transaction_compression=ON 时,节点性能会提高,但是cdc会监听不到增量数据变更,请问flinksql中可以在连接器中增加什么参数可以解决吗? binlog_format=ROWbinlog_transaction_compression=ON

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

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

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

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

在Flink CDC中通过cdc监听到的数据自动转换时间戳了,这么需要怎么处理下?

在Flink CDC中oracle数据库表字段是date类型的(年月日时分秒),通过cdc监听到的数据自动转换时间戳了,这么需要怎么处理下?

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

在Flink CDC中oraclecdc 有设置监听间隔时间的参数吗?

在Flink CDC中oraclecdc 有设置监听间隔时间的参数吗?

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

在Flink CDC中oraclecdc 监听新增的数据,有监听到重复的数据有解决方案吗?

在Flink CDC中oraclecdc 监听新增的数据,数据变动比较频繁,有监听到重复的数据有解决方案吗?

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

产品推荐

阿里云实时计算Flink

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

+关注