Flink Subtask 和 线程:深入理解执行模型
是的,在 Flink 中,每个 subtask 都会被分配到一个线程中执行。因此,可以将 subtask 简单地理解为线程。
每个 TaskManager 都有多个线程池,每个线程池对应一个 slot。当一个 TaskManager 运行一个 Job 时,每个 subtask 会被分配到一个 slot 中,并在该 slot 对应的线程池中的一个线程中执行。
需要注意的是,Flink 的 subtask 不是直接与操作系统的线程一一对应。Flink 可能会根据需要调整线程的数量和分配,以最大限度地利用硬件资源。
总而言之,可以将 Flink 的 subtask 简单地理解为线程,它代表了 Flink 中并行执行任务的基本单元。
原文地址: https://www.cveoy.top/t/topic/lCpl 著作权归作者所有。请勿转载和采集!