Session 集群是预先启动并持续运行的集群,可供多个作业在不同时间提交并共享资源执行,能减少作业启动的时间开销。而在本产品中 Session 集群主要是为了 Flink 用户快速调试 SQL 代码,诊断代码问题的工具。
Session 集群仅作为开发测试环境,不建议将 Session 集群用于正式的生产环境。
调试任务一般是由开发人员(Project_Dev)进行,需要已添加项目成员并为其关联角色,请参见添加项目成员。
配置 | 说明 | |
---|---|---|
基础配置:必填参数。 | ||
集群名称 | 自定义设置 Session 集群名称。 | |
Flink 资源池选择 | 从下拉列表中选择目标 Flink 资源池。 | |
引擎版本 | 目前支持 Flink 1.16-volcano 和 Flink 1.11-volcano 版本,建议选择与任务的引擎版本一致,否则调试任务时会提示引擎版本不匹配。 | |
资源配置:选填参数,系统已有默认基础资源配置。 | ||
Task Manager 设置 | Task Manager 最小数量 | TaskManager 的最小数量,默认为 1,支持调整为 0。 |
Task Manager 最大数量 | TaskManager 的最小数量,默认为 10。 | |
CPU | TaskManager 的 CPU 核数,默认值为 2,最小值为 0.5。 | |
内存 | TaskManager 的内存大小,将根据您设置的 CPU 核数自动调整,呈 1C4G 的关系。 | |
Slot 数量 | 推荐单 Slot 使用资源不少于 1 核 4 GiB,每个 Task Manager 可以配置 2 个 Slot。 | |
Job Manager 设置 | CPU | JobManager 的 CPU 核数,默认值为 1 核,最小值为 0.5。 |
内存 | JobManager 的内存大小,将根据您设置的 CPU 核数自动调整,呈 1C4G 的关系 | |
自定义参数 | 根据需要可自定义设置参数,格式为 Key-Value。 |
在资源管理 > Session 集群模块可以查看并管理当前项目下所有的 Session 集群。可以查看 Session 集群的名称、ID、状态、引擎版本、CPU、内存等信息。
Session 集群创建后,支持按需执行以下操作: