跳表
1
事务
1
clickhouse
1
数据传输
1
MemoryManagment
1
Slot
1
HA
1
Akka
1
RPC
1
ExecutionGraph
1
JobGraph
1
源码分析
3
StreamGraph
1
savepoint
savepoint
1
ConcurrentHashMap
1
ORC
1
snapshot
1
ABS算法
1
lock
2
thread
1
kafka-producer
1
kafkaproducer
partition
1
cgroup
1
HBase
1
LSM
2
B+树
1
SecondaryNmenode
1
NameNode
1
令牌桶
1
Guava
1
Flink CDC
1
Flink SQL
4
最佳实践
6
资源管理
2
维度表
1
调度
4
流批一体
2
join
2
Chain
1
Operator
1
ClassLoader
1
RocksDB
2
time
2
window
2
checkpoint
8
网络优化
1
watermark
3
背压
2
CEP
1
Shuffle
3
精确一致性
3
窗口
1
kafka-consumer
2
view
1
transformation
1
state
10
kudu
2
impala
2
内存管理
4
GC
1
Exception
1
多线程
1
YARN
1
MapReduce
2
HDFS
2
hadoop
0
Halo
0
Flink 源码阅读笔记(8)- Task 之间的数据传输
在这篇文章中,我们将探讨一个 Flink 作业在实际运行时,不同的 Task 之间是如何进行数据交换的。由于不同的 Task 可能并非运行在同一个 TaskManager 中,因而数据传输的过程中必然涉及到网络通信,文中也会对 Flink 的网络栈的实现,包括反压机制等,进行分析。 概览 Flink