为了更高效地分布式执行,Flink会尽可能地将operator的subtask链接在一起形成task。每个task在一个线程中执行。将operators链接成task是非常有效的优化:
·减少线程之间的切换,
·减少消息的序列化/反序列化,
·减少数据在缓冲区的交换,
·减少了延迟的同时提高整体的吞吐量。
标签:
笔试题
刷题
简历模板
AI算法
大数据
内推
内推: