FlinkTaskSubmissionException: No task slot allocated for job ID xx and allocation ID xx.

Posted 2022-02-23 九师兄

文章目录

• 1.概述

1.概述

flink任务提交报错 TaskSubmissionException: No task slot allocated for job ID xx and allocation ID xx.

我这边使用 operator 部署的，每个 taskmanager 对应一个 pod，如果 pod 很多的时候偶尔会出现这种异常，怀疑是不是某个 pod 挂了导致的

这个错误在源码中如下

/**
     * todo:注释:
     *   提交Task让TaskManager启动
     *   第一个参数: TaskDeploymentDescriptor 包含启动当前这个Task 所需要的一切信息
     *
     * @param tdd describing the task to submit
     * @param jobMasterId identifying the submitting JobMaster
     * @param timeout of the submit operation
     * @return
     */