0
点赞
收藏
分享

微信扫一扫

【Flink】TaskSubmissionException: No task slot allocated for job ID xx and allocation ID xx.

您好 2022-02-17 阅读 90
flink

文章目录


在这里插入图片描述

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
     */
  
举报

相关推荐

0 条评论