Apache Flink资源管理器(App Master)在第一个任务管理器在空闲超时后被杀死后无法分配新的任务管理器。
创始人
2024-09-04 02:00:51
0次

在Apache Flink中,可以通过设置slot.timeout属性来解决任务管理器空闲超时问题。以下是一个示例代码,说明如何设置slot.timeout属性:

import org.apache.flink.configuration.Configuration;
import org.apache.flink.configuration.JobManagerOptions;
import org.apache.flink.runtime.jobmaster.JobMaster;
import org.apache.flink.runtime.jobmaster.slotpool.SlotPool;
import org.apache.flink.runtime.jobmaster.slotpool.SlotReport;
import org.apache.flink.runtime.jobmaster.slotpool.SlotRequest;
import org.apache.flink.runtime.resourcemanager.ResourceManager;
import org.apache.flink.runtime.resourcemanager.SlotRequestTimeoutListener;
import org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager;
import org.apache.flink.runtime.taskexecutor.slot.SlotOffer;
import org.apache.flink.util.Preconditions;

import javax.annotation.Nullable;

public class CustomResourceManager extends ResourceManager {

    // 定义空闲超时时间
    private final long idleTimeout;

    public CustomResourceManager(
            Configuration configuration,
            SlotManager slotManager,
            SlotPool slotPool,
            JobMaster jobMaster,
            long idleTimeout) {
        super(configuration, slotManager, slotPool, jobMaster);

        Preconditions.checkArgument(idleTimeout >= 0, "Idle timeout must be >= 0");
        this.idleTimeout = idleTimeout;
    }

    @Override
    public void start() throws Exception {
        super.start();

        // 注册空闲超时监听器
        getFencingToken().getLeaderElectionService().addListener(
                new SlotRequestTimeoutListener(getFencingToken().toUUID(), getIdleTimeout()));
    }

    public long getIdleTimeout() {
        return idleTimeout;
    }

    public static CustomResourceManager create(
            Configuration configuration,
            SlotManager slotManager,
            SlotPool slotPool,
            JobMaster jobMaster,
            long idleTimeout) throws Exception {
        return new CustomResourceManager(configuration, slotManager, slotPool, jobMaster, idleTimeout);
    }

    public static void main(String[] args) throws Exception {
        Configuration configuration = new Configuration();
        // 设置任务管理器空闲超时时间为10分钟
        configuration.setLong(JobManagerOptions.SLOT_IDLE_TIMEOUT, 600000);

        // 创建自定义资源管理器
        CustomResourceManager resourceManager = create(
                configuration,
                slotManager,
                slotPool,
                jobMaster,
                600000);

        // 启动资源管理器
        resourceManager.start();
    }
}

在上述代码中,CustomResourceManager类继承自ResourceManager类,并添加了一个idleTimeout成员变量,表示任务管理器空闲超时时间。在start()方法中,注册了一个空闲超时监听器,当任务管理器空闲超时时,会触发该监听器。

在main()方法中,通过JobManagerOptions.SLOT_IDLE_TIMEOUT属性设置了任务管理器的空闲超时时间为10分钟(600000毫秒),然后创建了一个CustomResourceManager实例,并调用start()方法启动资源管理器。

请根据你的实际情况调整超时时间和其他配置。

相关内容

热门资讯

玩家必看教程!大赢家跑得快开挂... 玩家必看教程!大赢家跑得快开挂功能技巧,大赢家跑得快确实真的是有开挂技巧(有辅助挂教学)1、在大赢家...
玩家攻略推荐!德州扑克辅助器功... 玩家攻略推荐!德州扑克辅助器功能攻略,德州扑克好像有辅助器攻略(真的有辅助挂)1)德州扑克免费钻石:...
推荐一款!一起斗地主辅助功能神... 推荐一款!一起斗地主辅助功能神器,一起斗地主其实存在有辅助神器(有辅助挂教学)1、首先打开一起斗地主...
必看攻略!芷芷休闲透视挂功能软... 必看攻略!芷芷休闲透视挂功能软件,芷芷休闲都是有透视挂软件(有辅助挂方式)1、芷芷休闲有没有辅助教程...
2分钟细说!宝宝浙江开挂功能a... 2分钟细说!宝宝浙江开挂功能app,宝宝浙江都是是有开挂app(有辅助挂教学)小薇(辅助器软件下载)...
揭秘关于!棋牌游辅助功能攻略,... 揭秘关于!棋牌游辅助功能攻略,棋牌游竟然真的有辅助攻略(有辅助挂攻略)1.棋牌游 选牌创建新账号,点...
实测揭晓!七月游戏透视功能ap... 实测揭晓!七月游戏透视功能app,七月游戏确实是有透视app(有辅助挂猫腻)1、完成七月游戏辅助器v...
玩家必看科普!如意棋牌辅助器功... 玩家必看科普!如意棋牌辅助器功能工具,如意棋牌其实是真的有辅助器工具(有辅助挂详细)如意棋牌能透视中...
最新技巧!鼎盛棋牌开挂功能插件... 最新技巧!鼎盛棋牌开挂功能插件,鼎盛棋牌总是是有开挂插件(有辅助挂神器)1、在鼎盛棋牌插件功能辅助器...
揭秘一下!微友约局开挂功能教程... 揭秘一下!微友约局开挂功能教程,微友约局总是有开挂教程(真实有辅助挂)1、揭秘一下!微友约局开挂功能...