当前位置： 首页 > news >正文

Flink入门之核心概念（三）

news 文章来源：https://blog.csdn.net/qq_44273739/article/details/134801948 2025/5/8 22:58:48

任务槽

  • TaskSlots: 任务槽，是TaskManager提供的用于执行Task的资源（CPU + 内存）

  • TaskManager提供的TaskSlots的个数：主要由Taskmanager所在机器的CPU核心数来决定，不能超过CPU的最大核心数

    • 1.可以在flink/conf/flink-conf.yaml文件中的numberOfTaskSlot配置
    • 2.在yarn集群中运行flink时，任务槽的个数受到yarn中container的最大CPU数 vcores

  • 一个作业的Task数量如何确定？

    • 1.主要由算子数、算子链数、并行度共同来决定的
    • 2.如果禁用算子链合并，task的数量 = 算子数 * 并行度（并行度相同）
    • 3.如果存在算子链合并，task的数量 = 合并后的算子链数（包含不合并的算子）* 并行度（并行度相同）

  • Slot共享：flink允许将上下游的task共享给同一个slot。但是注意，同一个Task的并行子任务不允许共享

  • 为什么要Slot共享？

    • 1.当我们将资源密集型和非密集型的任务同时放到一个slot中，他们就可以自行分配对资源占用的比例，保证最重的活平均分配给所有的Taskmanager
    • 2.Slot共享另一个好处就是在一个Slot中可以保存完整的作业管道

  • 能不能不共享？

    • 通过设置共享组（算子.slotSharingGroup(“共享组名”)）来实现共享或者不共享，默认的共享组为default，从source端往后传递，如果下游的算子没有具体设置共享组

  • 一个作业的并行度如何确定？

    • 作业的并行度由当前作业中并行度最大的算子的并行度决定
    • 一个作业需要多少个TaskSlot如何确定？
    • 作业需要多少个taskSlot由作业的并行度决定（前提是slot共享）

Yarn应用模式作业提交流程

在这里插入图片描述

  1. 客户端提交任务，Yarn的ResourceManager启动AM
  2. AM中的Actor通信系统
    • 启动资源管理器
    • 启动分发器
      • 分发器启动JobMaster
  3. JobMaster
    • 生成逻辑流图
    • 生成作业流图
    • 生成执行流图
    • 向资源管理器 注册请求Slot
  4. 资源管理器向Yarn的Resource manager申请资源
  5. Resource Manager启动TaskManager
  6. TaskManager向AM中的资源管理器注册需要的Slot
  7. AM的资源管理器分配slot给TaskManager
  8. JobMaster获取目前TaskManager现有的Slot个数
  9. JobMaster分配任务给各个TaskManager，各个TaskManager生成相应的物理流图并执行。

相关文章：

Flink入门之核心概念（三）

任务槽 TaskSlots: 任务槽，是TaskManager提供的用于执行Task的资源（CPU 内存） TaskManager提供的TaskSlots的个数：主要由Taskmanager所在机器的CPU核心数来决定，不能超过CPU的最大核心数 1.可以在flink/conf/flink-c…...

编程日记 2023/12/9 14:52:30

算法备胎hash和队列的特征——第五关青铜挑战

内容1.Hash存储方式2.Hash处理冲突的方式3.队列存储的基本特征4.如何使用链表来实现栈 1.Hash 基础 1.1Hash的概念和基本特征 哈希（Hash）也称为散列，就是把任意长度的输入，通过散列算法，变换成固定长度的输出&#…...

编程日记 2023/12/9 14:51:29

LLM之Agent（五）| AgentTuning：清华大学与智谱AI提出AgentTuning提高大语言模型Agent能力

​论文地址：https://arxiv.org/pdf/2310.12823.pdf Github地址：https://github.com/THUDM/AgentTuning 在ChatGPT带来了大模型的蓬勃发展，开源LLM层出不穷，虽然这些开源的LLM在各自任务中表现出色，但是在真实环境下作…...

编程日记 2023/12/9 14:50:28

LLM之Agent（三）：HuggingGPT根据用户需求自动调用Huggingface合适的模型

​ 浙大和微软亚洲研究院开源的HuggingGPT，又名JARVIS，它可以根据用户的自然语言描述的需求就可以自动分析需要哪些AI模型，然后去Huggingface上直接调用对应的模型，最终给出用户的解决方案。 一、HuggingGPT的工作流程 它的…...

编程日记 2023/12/9 14:48:26

【上海大学数字逻辑实验报告】五、记忆元件测试

一、实验目的 掌握R-S触发器、D触发器和JK触发器的工作原理及其相互转换。学会用74LS00芯片构成钟控RS触发器。学会用74LS112实现D触发器学会在Quartus II上用D触发器实现JK触发器。 二、实验原理 基本R-S触发器是直接复位-置位的触发器，它是构成各种功能的触发器…...

编程日记 2023/12/9 14:44:23

yaml工作常用语法总结

文章目录 yaml中的| 符号 和 > 符号yaml中的 - 符号工作中常遇到的问题- 命令行中有冒号加空格，导致yaml解析报错 yaml中的| 符号 和 > 符号 在 YAML 中，| 符号表示标量块（Scalar Block）的开始。它用于表示长文本块或保持多…...

编程日记 2023/12/9 14:42:21

bash中通过变量中的内容获取对应的关联数组

bash中通过变量中的内容获取对应的关联数组 Bash declare 手册： https://phoenixnap.com/kb/bash-declare 实际问题： 在 bash 中创建了多个关联数组，需要根据输入的值，获取不同的关联数组。 可以使用 if 进行多次判断&#xff…...

编程日记 2023/12/9 14:39:19

Redis Geo操作地理位置

Redis Geo 使用场景API列表名词API列表Springboot使用mavenyamlTest 注意事项 Redis Geo 是Redis在3.2版本中新增的功能，用于存储和操作地理位置信息 使用场景 滴滴打车：这是一个对地理位置精度要求较高的场景。通过使用Redis的GEO功能，滴滴…...

编程日记 2023/12/9 14:37:17

市面上的AR眼镜：优缺点分析

AR眼镜是近年来备受关注的科技产品之一。它通过将虚拟信息叠加到现实世界中，为用户提供全新的视觉体验。目前，市面上的AR眼镜主要分为两类：消费级AR眼镜和企业级AR眼镜。 消费级AR眼镜 消费级AR眼镜的特点是轻便、时尚、易于佩戴&#xff0…...

编程日记 2023/12/9 14:35:15

2024年湖南省职业院校技能竞赛高职组电子与信息专业类软件测试赛项竞赛规程及样题

湖南省职业院校技能竞赛 高职组电子与信息专业类软件测试赛项竞赛规程及样题 一、竞赛内容 1.本赛项考查的技术技能和涵盖的职业典型工作任务 任务项 任务名称 职业典型工作任务 任务一 功能测试 测试计划、测试报告文档设计与编写、测试用例 设计、测试执行和 Bug记录 任务二…...

编程日记 2023/12/9 14:32:13

10、pytest通过assert进行断言

官方实例 # content of test_assert1.pydef f():return 3def test_function():assert f() 4def test_assert_desc():a f()# assert a % 2 0assert a % 2 0, "value was odd, should be even"解读与实操 pytest允许你使用标准python断言来验证测试中的期望值&am…...

编程日记 2023/12/9 14:31:12

Webpack技术入门与实践

1.概念： 本质上， webpack是一个现代JavaScript应用程序的静态模块打包器，当webpack处理应用程序时，它会递归地构建一个依赖关系图，其中包含应用程序需要的每个模块，然后将所有这些模块打包成一个或多个bund…...

编程日记 2023/12/9 14:29:10

HarmonyOS开发(九)：数据管理

1、概述 1.1、功能简介 数据管理为开发者提供数据存储、数据管理能力。 它分为两个部分： 数据存储：提供通用数据持久化能力，根据数据特点，分为用户首选项、键值型数据库和关系型数据库。数据管理：提供高效的数据管…...

编程日记 2023/12/9 14:24:07

acwing-Linux学习笔记

acwing-Linux课上的笔记 acwing-Linux网址 文章目录 1.1常用文件管理命令homework作业测评命令 2.1 简单的介绍tmux与vimvimhomeworktmux教程vim教程homework中的一些操作 3 shell语法概论注释变量默认变量数组expr命令read命令echo命令printf命令test命令与判断符号[]逻辑运算…...

编程日记 2023/12/9 14:22:05

Python渗透测试——一、数据包的编辑工具——Scapy

Python渗透测试 一、Scapy简介二、Scapy中的分层结构三、Scapy中的常用函数四、在Scapy 中发送和接收数据包五、Scapy 中的抓包函数 一、Scapy简介 提到数据包(这里泛指帧、段和报文等)的构造，我们首先需要了解协议和分层这两个概念。在“互联世界的规则一协议”中…...

编程日记 2023/12/9 14:20:04

使用webstrom编写vue开启提示

1.语言服务器选择 2.文件类型–忽略的文件和文件夹，删去，node_modules，就可以点进去库了 3.禁用JSLint、TSLint 4.开启node辅助 5.如果是vite，开启自动读取，或手动指定 6.如果是Webpack，开启自动读取&#…...

编程日记 2023/12/9 14:17:01

linux远程桌面管理工具（xrdp）、向日葵

Windows远程桌面 linux远程桌面 使用向日葵远程桌面（手机端同理） Windows远程桌面 微软自带Remote Desktop Connection Manager （RDCMan）远程控制管理软件介绍 远程桌面连接管理器 v2.93 linux远程桌面 Windows远程桌面Ubunt…...

编程日记 2023/12/9 14:13:58

【力扣100】8.找到字符串中所有字母异位词

添加链接描述 class Solution:def findAnagrams(self, s: str, p: str) -> List[int]:sildingstrresult[]p.join(sorted(p))for i in range(len(s)):if len(sildingstr)<len(p):sildingstrsildingstrs[i]# print(sildingstr)if len(sildingstr)len(p):sort_sildingstr.j…...

编程日记 2023/12/9 14:12:57

圆通速递查询，圆通速递单号查询，用表格导出查询好的物流信息

批量查询圆通速递单号的物流信息&#xff0c;以表格的形式导出查询好的物流信息。 所需工具&#xff1a; 一个【快递批量查询高手】软件 圆通速递单号若干 操作步骤&#xff1a; 步骤1&#xff1a;运行【快递批量查询高手】软件&#xff0c;并登录 步骤2&#xff1a;点击主界…...

编程日记 2023/12/9 14:11:56

FLStudio中文2024中文最新汉化安装包下载

FLStudio中文21最新版本以其使用速度而闻名&#xff0c;是一个高度复杂的音乐制作环境。FL Studio免费&#xff0c;联合国音序器音频和MIDI每个复合编辑都是音乐。现代的DAW是一种非凡的野兽。首先&#xff0c;它在很大程度上把自己放在了(几乎)每个人记录过程的核心。其次&…...

编程日记 2023/12/9 14:09:54

AI：大语言模型训练方法 - 机器学习

Transformer Transformer是一种深度学习的模型架构&#xff0c;特别适用于自然语言处理任务。Transformer 模型的核心创新在于其 "自注意力"&#xff08;Self-Attention&#xff09;机制&#xff0c;这种机制使得模型可以有效地捕捉输入数据中的长距离依赖关系。 T…...

编程日记 2023/12/9 14:08:53

Linux（17）：认识与分析登录档

什么是登录档 【详细而确实的分析以及备份系统的登录文件】是一个系统管理员应该要进行的任务之一。 登录档 就是记录系统活动信息的几个文件&#xff0c;例如&#xff1a;何时、何地(来源IP)、何人(什么服务名称)、做了什么动作(讯息登录啰)。 换句话说就是&#xff1a;记录系…...

编程日记 2023/12/9 14:07:52

STM32上模拟CH340芯片的功能 （一）

#虚拟串口模拟CH340# 代码gitee地址&#xff1a;STM32F103_CH340: 用STM32模拟ch340USB串口的功能 一、思路 1. 确定通信接口&#xff1a;CH340是一款USB转串口芯片&#xff0c;因此您需要选择STM32上的某个USB接口来实现USB通信。通常情况下&#xff0c;STM32系列芯片都有内…...

编程日记 2023/12/9 14:06:51

图论——最小生成树

图论——最小生成树 A wise man changes his mind, a fool never will 生成树 一个连通图的生成树是一个极小的连通子图&#xff0c;它包含图中全部的n个顶点&#xff0c;但只有构成一棵树的n-1条边。 最小生成树 在这些边中选择N-1条出来&#xff0c;连接所有的N个点。这N-1…...

编程日记 2023/12/9 14:03:49

C++基础 -42- STL库之list链表

———————STL库之list链表——————— &#x1f384; list链表的格式(需要定义头文件) list<int> data1(4, 100);list<int> data2(4, 500);&#x1f384;list链表的合并接口 &#x1f384;举例使用合并接口并且验证 data2.merge(data1);list<int>::…...

编程日记 2023/12/9 13:59:45

Backend - Python 序列化

目录 一、作用1&#xff1a;代码块存入数据库 二、作用2&#xff1a;前后端传递数据 &#xff08;一&#xff09;前端 1. JSON.stringify() 2. JSON.parse() &#xff08;二&#xff09;后端 1. json.dumps() &#xff08;1&#xff09;作用 &#xff08;2&#xff09…...

编程日记 2023/12/9 13:56:43

初级数据结构（一）——顺序表

文中代码源文件已上传&#xff1a;数据结构源码 <-上一篇 NULL | 初级数据结构&#xff08;二&#xff09;——链表 下一篇-> 1、顺序表的特点 1.1、数组 现实中数据记录一般都记录在表格中&#xff0c;如进货单、菜单等&#xff0c;它们的最大特点就是…...

编程日记 2023/12/9 13:54:41

实现：切换页面切换标题，扩展 vue-router 的类型

布局容器-页面标题 网址&#xff1a;https://router.vuejs.org/zh/guide/advanced/meta 给每一个路由添加 元信息 数据 router/index.ts const router createRouter({history: createWebHistory(import.meta.env.BASE_URL),routes: [{ path: /login, component: () > im…...

编程日记 2023/12/9 13:51:39

已通过考试和认证注册以及后续计划表

已通过考试和认证注册以及后续计划表 软考 - 计算机技术与软件专业技术资格&#xff08;水平&#xff09;考试信息系统集成及服务项目管理人员工程类考试计划你关注的证书样子 软考 - 计算机技术与软件专业技术资格&#xff08;水平&#xff09;考试 高级 信息系统项目管理师&…...

编程日记 2023/12/9 13:50:38

开源计算机视觉库OpenCV详解

目录 1、概述 2、OpenCV详细介绍 2.1、OpenCV的起源 2.2、OpenCV开发语言 2.3、OpenCV的应用领域 3、OpenCV模块划分 4、OpenCV源码文件结构 4.1、根目录介绍 4.2、常用模块介绍 4.3、CUDA加速模块 5、OpenCV配置以及Visual Studio使用OpenCV 6、关于Lena图片 7、…...

编程日记 2023/12/9 13:49:37