Dav*_*son 10
此处说明了任务和子任务-https : //ci.apache.org/projects/flink/flink-docs-release-1.7/concepts/runtime.html#tasks-and-operator-chains:
任务是一个抽象概念,代表可以在单个线程中执行的一系列操作符。诸如keyBy(这会导致网络改组通过某个密钥对流进行划分)之类的事情,或者管线并行性的变化都会破坏链接,并迫使运营商分担不同的任务。在上图中,该应用程序具有三个任务。
子任务是任务的一个并行切片。这是可调度的,可运行的执行单元。在上图中,源/地图和keyBy / Window / apply任务的应用程序并行度为2,接收器的并行度为1,因此总共运行了5个子任务。
作业是应用程序的运行实例。客户将作业提交给作业管理器,作业将其切成子任务并安排这些子任务供任务管理器执行。
| 归档时间: |
|
| 查看次数: |
603 次 |
| 最近记录: |