2.什么是 Slot

2.1 概述

Flink中每个真正执行任务的TaskManager都是一个JVM进程，其在多线程环境中执行一个或者多个子任务。为了控制一个JVM同时能运行的任务数量，flink引入了task slot的概念。每一个task solt代表了TaskManager资源的一个子集，比如，一个拥有3个solt的TaskManager,每一个solt可以使用1/3TM所管理的内存。进行资源分割意味着为子任务保留足够的内存，从而避免与其他子任务进行竞争。注意：当前solt还不能分割cpu资源，仅仅对内存进行了分割。

通过调整TM`solt`的数量，用户可以确定子任务的隔离程度，比如，每个TM只设置一个`solt`，那么就意味着每一个任务组都在单独的JVM中执行。共用JVM的任务可以共享TCP链接，心跳消息，甚至可能共享数据集。

默认情况下，flink允许子任务共享slot只要这些子任务属于同一job。允许solt共享主要有以下两方面的好处:

flink计算一个job所需<

95-235-038-源码-task-Task Slot相关推荐

【flink】Flink 1.12.2 源码浅析 : Task 浅析
1.概述转载:Flink 1.12.2 源码浅析 : Task 浅析 Task 表示TaskManager上并行 subtask 的一次执行. Task封装了一个Flink operator(也可能 ...
【flink】Flink 1.12.2 源码浅析 : Task数据输入
1.概述转载:Flink 1.12.2 源码浅析 : Task数据输入在 Task 中,InputGate 是对输入的封装,InputGate 是和 JobGraph 中 JobEdge 一一对应 ...
【flink】Flink 1.12.2 源码浅析 :Task数据输出
1.概述转载:Flink 1.12.2 源码浅析 :Task数据输出 Stream的计算模型采用的是PUSH模式, 上游主动向下游推送数据, 上下游之间采用生产者-消费者模式, 下游收到数据触发计算 ...
celery源码分析-Task的初始化与发送任务
celery源码分析本文环境python3.5.2,celery4.0.2,django1.10.x系列 celery的任务发送在Django项目中使用了装饰器来包装待执行任务, from cel ...
用pry阅读ruby源码--以task方法为例
rails项目中有个目录 lib/tasks,里面定义了一个rake任务: task hello: :hello do puts "hello" end 看到这里的时候,是不是可能 ...
Spark源码分析 – DAGScheduler
DAGScheduler的架构其实非常简单, 1. eventQueue, 所有需要DAGScheduler处理的事情都需要往eventQueue中发送event 2. eventLoop Threa ...
鸿蒙内核源码分析系列 | 读懂HarmonyOS内核源代码！
本系列从HarmonyOS架构层视角整理成文, 并用生活场景及讲故事的方式试图去解构内核,一窥究竟.帮助你读懂并快速理解鸿蒙操作系统源码. 1.鸿蒙内核源码分析(调度机制篇) 2.鸿蒙内核源码分析(进 ...
vue甘特图(内网引入gantt-elastic以及源码扩展)
前言:项目要求用甘特图展示计划的实施过程.之前用过dhtmlx,用着不是很舒服.又在网上看了jQueryGantt-master,wl-gantt-mater,gantt-elastic的大概源码,最 ...
【珍藏】 2012.NET开发必看资料53个+经典源码77个—下载目录
2019独角兽企业重金招聘Python工程师标准>>> .NET 是 Microsoft XML Web services 平台.XML Web services 允许应用程序通过I ...
lisp源码微盘_Lisp-200 LISP源码200例 - 下载 - 搜珍网
Lisp源码200例/3DIMYX.LSP Lisp源码200例/3DIMZS.LSP Lisp源码200例/AAR.LSP Lisp源码200例/ABL.LSP Lisp源码200例/ABLOCK. ...

95-235-038-源码-task-Task Slot

2.什么是 Slot

2.1 概述

95-235-038-源码-task-Task Slot相关推荐

最新文章

热门文章