阿里云文档 2025-01-17

Sink变更兼容性

本文为您介绍Sink变更的可兼容性和不可兼容性详情。

阿里云文档 2024-07-10

SQL变更的其他兼容性限制

本文为您介绍变更SQL除Query、Source和Sink之外的其他限制。

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

Flink使用区间join 的时候sink到表,时间会晚上几分钟,是哪里的问题?

Flink使用区间join 的时候sink到表,时间会晚上几分钟,是哪里的问题?

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

flink cdc 有少量数据没同步过来?多表join,有个表的字段变更了,这边没同步到sink表

flink cdc 有少量数据没同步过来?多表join,有个表的字段变更了,这边没同步到sink表

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

大佬们,我用Flink CDC做多表join,有一张源表某个字段变化很平凡,导致我的sink表变化?

大佬们,我用Flink CDC做多表join,有一张源表某个字段变化很平凡,导致我的sink表变化很频繁,但是我不关注那个表的那个字段,怎么让sink表的数据相对稳定呢?

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

老哥们 请教一个Flink CDC 问题,使用了lookup join 过后 sink不输出数据,也

老哥们 请教一个Flink CDC 问题,使用了lookup join 过后 sink不输出数据,也没报错 一般是什么原因呢? select 又能查到数据 ,去掉lookup join 就可以了

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

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更新不了全部列的数据,这种情况有什...

问答 2022-02-15 来自:开发者社区

flink双流Join Sink丢数据的问题

DataStream a = environment.addSource(new KafkaSource(AppConst.A)); a.addSink(new KuduSink<>()); DataStream b = environment.addSource(new KafkaSource(AppConst.B)); DataStream dat...

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

产品推荐

实时计算 Flink

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

+关注