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

为啥我用flink cdc没有监听到mysql的数据变化呢?

为啥我用flink cdc没有监听到mysql的数据变化呢?

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

对于Flink CDC,mysql的维表和实时数据join的结果又写入维表,怎么实现?

对于Flink CDC,mysql的维表和实时数据join的结果又写入维表,这种实时join维表场景怎么实现?

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

flink1.15.3 cdc 2.3 mysql,读取不到数据???

flink1.15.3 cdc 2.3 mysql CREATE TABLE source_mysql ( id INT PRIMARY KEY NOT ENFORCED, name STRING, logo_url STRING, create_time TIMESTAMP(3)) WITH ( 'connector' = 'mysql-cdc', 'hostname' = '192.168.....

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

用Flink cdc 读取MySQL数据时报错为什么?

Flink 版本是1.15.2 MySQL 是8.0.30 ,用Flink cdc 读取MySQL数据时报错为什么?是我的依赖包有缺失吗,还是有冲突啊?

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

Flink CDC datax 可以支持实时同步mysql 数据么?

Flink CDC datax 可以支持实时同步mysql 数据么?

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

flink cdc mysql 可以同步删除的数据吗?

flink cdc mysql 可以同步删除的数据吗?

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

对于Flink CDC,想把cdc MySQL binlog 的数据。怎么设计好呢?

对于Flink CDC,想把cdc MySQL binlog 的数据。推进Kafka 功其他业务消费。 同时又要按每小时做预聚合统计。 然后写到starrocks 这个怎么设计好呢?

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

对于Flink CDC,mysql分库分表入iceberg的V2表,任务重启时为啥历史数据重复写入?

对于Flink CDC,mysql分库分表入iceberg的V2表,在任务重启时为啥历史数据会重复写入,并且时区有的正确有的-8小时,有大佬知道怎么解决吗

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

请问flink sql cdc同步同一个mongo数据源到mysql中数据条目正确,但同步是到dor

请问flink sql cdc同步同一个mongo数据源到mysql中数据条目正确,但同步是到doris中数据存在很多重复数据 是啥原因?

问答 2022-12-27 来自:开发者社区

用的flink 1.14,cdc 2.3版本,同步mysql中json格式数据,有的时候会乱码,目前

用的flink 1.14,cdc 2.3版本,同步mysql中json格式数据,有的时候会乱码,目前推测是这个json 的长度过长导致的咋办?

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

产品推荐

阿里云实时计算Flink

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

+关注