dp1
hello dp1
ExecutionEdge
表示 ExecutionVertex 的输入，source 是 IntermediateResultPartition，target是ExecutionVertex。source和target都只能是一个。
Execution
是执行一个 ExecutionVertex 的一次尝试。当发生故障或者数据需要重算的情况下 ExecutionVertex 可能会有多个ExecutionAttemptID。一个 Execution 通过 ExecutionAttemptID 来唯一标识。JM和TM之间关于 task 的部署和 task status 的更新都是通过ExecutionAttemptID 来确定消息接受者。
二、源码
评论
ValineTwikoo
公告
喜欢本博客的话可以扫描下方二维码加我 QQ, 有福利哦😯～。
通讯录
书籍 5
Hadoop 2.X 源码剖析
以Hadoop 2.6.0源码为基础, 深入剖析了HDFS 2.X中各个模块的实现细节。
Spark SQL 内核剖析
2018年08月电子工业出版社出版的图书。
高性能 MySQL 第3版
MySQL 领域的经典之作
深入理解 Kafka_核心设计与实践原理
我喜欢的一本有关 Kafka 的书籍之一～
Apache-Kafka 源码剖析
本书以 Kafka 0.10.0 版本源码为基础, 针对 Kafka 的架构设计到实现细节进行详细阐述～
开源项目～ 7
Flink
Stateful Computations over Data Streams
Hadoop
Open-source software for reliable, scalable, distributed computing.
Spark
Unified engine for large-scale data analytics
Iceberg
Iceberg is a high-performance format for huge analytic tables
Hudi
Apache Hudi is a transactional data lake platform
Kubernetes
Production-Grade Container Orchestration
Paimon
Streaming data lake platform.
