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

flink里怎么解决物理删除，join表时，数据混乱的问题。

展开

收起

游客3oewgrzrf6o5c 2022-07-25 18:32:15 687 版权

1 条回答

写回答

取消提交回答

叶秋学长

全栈JAVA领域创作者
您好！在 Flink 中，物理删除表时，join 表时数据混乱的问题可能是由于以下原因引起的：
- Join 操作的顺序不正确。
- Join 操作的并行度设置不合理。
- Join 操作的数据源不一致。
解决这些问题的方法可能包括：
- 确保 Join 操作的顺序正确。
- 确保 Join 操作的并行度设置合理。
- 确保 Join 操作的数据源一致。
2023-07-20 08:04:53

赞同展开评论

问答分类：

流计算实时计算 Flink版

问答标签：

实时计算 Flink版数据实时计算 Flink版join 实时计算 Flink版物理实时计算 Flink版join数据实时计算 Flink版怎么解决

问答地址：

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

相关问答

实时计算 Flink版

实时计算Flink任务同时往一个物理表中插入不同字段数据有什么影响

flink1.17.2的 flink sql的lookup join支持对维表字段的过滤吗?

216

flinkcdc1.13版本自定义实现connector，join流有输入，但是没有输出，怎么解决？

170

在Flink CDC中，flink sql lookup join 不支持维表的where 条件嘛？

166

Flink MySQL物理删除是否会影响到物理计数

Flink cdc source Records Sent比物理表数据量大

flink sql在关联多个动态表时,运行一两天就会崩掉，报checkpoint超时，怎么解决？

167

跑flink程序的时候报这样的错误怎么解决？

276

Flink调试的时候有多个sink下面的数据展示会错乱，怎么解决？

flink cdc 实时同步oracel 12 物理备份库的报错是什么原因？是不支持备份库吗

116

大数据与机器学习

实时计算 Flink

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

我要提问

收录在圈子:

阿里云实时计算Flink

199212

+ 订阅

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