全部面试刷题微服务数据库消息队列搜索引擎大数据运维 go语言人工智能

什么是槽共享组（Slot Sharing Group）？如何配置？

提问者：帅平问题分类：面试刷题

Flink面试题

发布于：4小时前 IP属地：

1 个回答

一闪一闪亮晶晶べ

槽共享组（Slot Sharing Group）是用于控制不同任务（Task）在同一个Slot中的共存规则，实现资源隔离或优化资源利用。
具体配置方法有：
1、通过api指定组名

DataStream<String> data = env.addSource(source)
    .slotSharingGroup("group1")  // 指定该算子所属组
    .map(...)
    .slotSharingGroup("group2"); // 切换组

2、在flink-conf.yaml中配置

taskmanager.numberOfTaskSlots: 4     # 每个TaskManager的Slot数

3、如果要禁用的话配置为0即可

cluster.taskmanager.slot.timeout: 0  # 禁用Slot超时释放（资源严格隔离）

发布于：4小时前 IP属地：

我来回答