文章目录
- 1.概述
- 2.源码分析
- 2.1 BinaryExternalSorter构造函数
- 2.2 启动方法
- 2.3 溢出线程
- 2.4 go函数
- 2.4.1 In-Memory Merge
- 2.4.2 Spilling Phase
1.概述
flink batch sql 好几换个任务有如下打印 Flink here spill the th sort buffer data with bytes and compressed bytes
先说结论:这个是 BinaryExternalSorter是一个完全成熟的二进制格式排序器。它实现了多路归并排序。在内部,它有三个异步线程(排序、溢出、合并),它们通过一组阻塞的循环队列进行通信,