package com.ruoshui.flink.ao;

/**
 * @author xinjingruoshui
 * @Description:
 * @date 2022-09-22
 * @time 19:59
 */
public interface TaskServiceAO {

    /**
     * 检查任务状态一致性问题（任务是不是挂掉）
     * <p>
     * 如：数据库里面任务状态是运行中，实际任务在集群上已经挂掉啦
     *
     * @author xinjingruoshui
     * @date 2022-09-22
     * @time 23:00
     */
    void checkJobStatus();


    /**
     * 检查yarn上任务存在 但是状态已经停止，这个时候停止Yarn任务
     *
     * @author xinjingruoshui
     * @date 2022-10-25
     * @time 17:15
     */
    @Deprecated
    void checkYarnJobByStop();


    /**
     * 针对在线运行任务进行自动SavePoint
     *
     * @author xinjingruoshui
     * @date 2022-09-22
     * @time 23:25
     */
    void autoSavePoint();


}
