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

Flink CDC. 可以将mysql数据sink到 hbase么?

作为维表

问答 2022-03-22 来自:开发者社区

flink CDC使用join的时候表更新如何反馈到sink table

Meta Source:【①群】Apache Flink China社区 Time:2021/11/10 10:44 Proposer:王杰 Status:Unresovled Content 王杰 flink cdc 做数据打宽,insert into C select * from A JION B 在第一次同步到数据后,T+1场景单独更新A或者B,C更新不了全部列的数据,这种情况有什...

问答 2021-12-06 来自:开发者社区

flink sql 1.11 kafka cdc与holo sink有一些问题

flink sql 1.11 创建kafka source 表 ,kafka数据是canal采集的mysql 信息,'format' = 'canal-json', 问题是 1,在source表中只能有与msyql对应的schema信息么,(也就是data[{}]里面的字段)能不能获取table,ts这种字段的值? 2,对于一个topic中有多张mysql binlog信息的表,kafka so....

问答 2021-12-06 来自:开发者社区

flink 1.11.2 cdc: cdc sql 结果表的sink顺序问题, 不同并行度下从sav

源表test: CREATE TABLE test ( id INT, name VARCHAR(255), time TIMESTAMP(3), status INT, PRIMARY KEY(id) NOT ENFORCED ) WITH ( 'connector' = 'mysql-cdc', 'hostname' = 'localhost', 'port' = '3306', 'user....

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

产品推荐

阿里云实时计算Flink

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

+关注