开发者社区大数据与机器学习实时计算 Flink 正文

在从mysql合宽表（left join）到iceberg的时候，iceberg commit 记录

在从mysql合宽表（left join）到iceberg的时候，iceberg commit 记录接收很少，最终任务失败，这种是什么原因呢？

展开

收起

爱喝咖啡嘿 2022-12-20 14:44:59 357 版权

1 条回答

写回答

取消提交回答

co63oc_

GitHub https://github.com/co63oc/cloud

https://zhuanlan.zhihu.com/p/454523635 Iceberg 数据提交流程

2022-12-25 12:13:10

赞同展开评论

问答分类：

关系型数据库 MySQL 云数据库 RDS MySQL 版

问答标签：

云数据库 RDS MySQL 版join 云数据库 RDS MySQL 版left 云数据库 RDS MySQL 版left join 云原生多模数据库Lindorm join 云数据库 RDS MySQL 版commit

问答地址：

开发者社区 > 大数据与机器学习 > 实时计算 Flink > 问答

相关问答

实时计算 Flink版

有人遇到Flink CDC里 mysql作为维表 lookup join where条件不生效嘛？

请问下Flink，需求做一个宽表，有大量大表join，如果需要跑大数据量的历史数据该怎么处理？

flink cdc抽mysql中的数据和实时数据流进行join，托管内存为什么会直接被拉满？

Flink mysql双流join时右表会有部分数据join不到

114

AnalyticDB MySQL如何使用Nested Loop Join

RDS执行JOIN查询语句报错Query exceeded reserved memory l...

请问大佬Flink CDC双流join能同步删除吗？我是直接flink mysql cdc ->

138

Flink CDC里之前用mysql数据库join比较慢，这种join性能会比较好吗？

126

PolarDB中mysql我强制两表用hash join . 用BNL() hint无效。怎么回事？

Flink CDC 中在获取mysql 表数据的时候，如果多张表 join 时全量获取数据吗？

152

大数据与机器学习

实时计算 Flink

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

我要提问

收录在圈子:

阿里云实时计算Flink

199210

+ 订阅

实时计算 Flink 版（Alibaba Cloud Realtime Compute for Apache Flink，Powered by Ververica）是阿里云基于 Apache Flink 构建的企业级、高性能实时大数据处理系统，由 Apache Flink 创始团队官方出品，拥有全球统一商业化品牌，完全兼容开源 Flink API，提供丰富的企业级增值功能。

如何在宝塔mysql修改掉3306端口

简单聊聊MySQL的三大日志（Redo Log、Binlog和Undo Log）各有什么区别

SQL为什么不建议执行多表关联查询

MySQL复制以及调优

Nexpose 7.10.0 发布，新增功能概览

在从mysql合宽表（left join）到iceberg的时候，iceberg commit 记录

实时计算 Flink

相关文章

热门讨论

热门文章