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

Flink operator 合并具体条件有哪些

展开

收起

一人吃饱，全家不饿 2021-01-06 11:38:19 898 版权

1 条回答

写回答

取消提交回答

一人吃饱，全家不饿
1. 下游节点只有一个输入。
2. 下游节点的操作符不为 null。
3. 上游节点的操作符不为 null。
4. 上下游节点在一个槽位共享组内。
5. 下游节点的连接策略是 ALWAYS。
6. 上游节点的连接策略是 HEAD 或者 ALWAYS。
7. edge 的分区函数是 ForwardPartitioner 的实例。
8. 上下游节点的并行度相等。
9. 可以进行节点连接操作。
2021-01-06 11:38:26

赞同展开评论

问答分类：

流计算实时计算 Flink版

问答标签：

实时计算 Flink版operator 实时计算 Flink版合并实时计算 Flink版operator合并实时计算 Flink版ator

问答地址：

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

相关问答

实时计算 Flink版

Flink operator合并具体条件有哪些

Flink Job Operator 的自愈修复功能是如何工作的？

如何通过 Flink Job Operator 实现性能优化？

Flink Job Operator 的升级能力具体指什么？

Flink Job Operator 的作用是什么？

在Flink CDC中operator 1.8说支持flink 1.18，但是启动显示不支持？

Flink宽表如何合并

Flink任务中为什么要为每个operator生成hash值

Flink没有Operator级别的数据量Metrics

710

Flink没有Operator级别的数据量Metrics吗？

905

大数据与机器学习

实时计算 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，提供丰富的企业级增值功能。

从嵌入式状态管理到云原生架构：Apache Flink 的演进与下一代增量计算范式

抖音基于 Flink 的 DataOps 能力实践

使用Koopman理论识别机器人动力学的非线性系统（Matlab代码实现）

零代码2小时搭建一套轻量级ERP系统

规则引擎开发现在已经演化成算法引擎了

Flink operator 合并具体条件有哪些

实时计算 Flink

相关文章

热门讨论

热门文章