apache/flink · error · IllegalArgumentException

Base job ID %s is not found in the recovered jobs.

Error message

Base job ID %s is not found in the recovered jobs.

What it means

Error "Base job ID %s is not found in the recovered jobs." thrown in apache/flink.

Source

Thrown at flink-clients/src/main/java/org/apache/flink/client/program/JobNameBasedJobIdManager.java:85

     * Creates a new job ID manager with the given base job ID and recovered job information.
     *
     * @param baseJobId the base job ID used as the origin for deriving all job IDs
     * @param allRecoveredJobInfos a collection of recovered job information; if non-empty, it
     *     <b>must contain</b> a job with ID equal to {@code baseJobId}
     */
    public JobNameBasedJobIdManager(JobID baseJobId, Collection<JobInfo> allRecoveredJobInfos) {
        this.baseJobId = checkNotNull(baseJobId);
        checkNotNull(allRecoveredJobInfos);

        if (!allRecoveredJobInfos.isEmpty()) {
            // step 1: find the first job name
            Optional<JobInfo> optionalBaseJobInfo =
                    allRecoveredJobInfos.stream()
                            .filter(jobInfo -> jobInfo.getJobId().equals(baseJobId))
                            .findFirst();

            if (optionalBaseJobInfo.isEmpty()) {
                throw new IllegalArgumentException(
                        String.format(
                                "Base job ID %s is not found in the recovered jobs.", baseJobId));
            }

            this.firstJobName = optionalBaseJobInfo.get().getJobName();

            // step 2: group jobs by job name and sort then according to the job index
            Map<String, List<JobID>> grouped =
                    allRecoveredJobInfos.stream()
                            .collect(
                                    Collectors.groupingBy(
                                            JobInfo::getJobName,
                                            Collectors.mapping(
                                                    JobInfo::getJobId, Collectors.toList())));

            for (Map.Entry<String, List<JobID>> entry : grouped.entrySet()) {
                String jobName = entry.getKey();
                List<JobID> jobIds = entry.getValue();

View on GitHub (pinned to 2f3c205e92)

Solutions

1. Address the cause reported by the error message: Base job ID the reported value is not found in the recovered jobs.
2. Verify the inputs, configuration values, and classpath/dependency setup related to this operation, then retry.

Example fix

Correct the condition described ("Base job ID the reported value is not found in the recovered jobs.") and rerun the job or command.

When it happens

Trigger: Triggered at runtime when the operation fails because: Base job ID the reported value is not found in the recovered jobs.

Common situations: Commonly caused by misconfiguration, missing dependencies or files, unsupported types or operations, or invalid user input leading to: Base job ID the reported value is not found in the recovered jobs.

AI-assisted analysis of apache/flink@2f3c205e92 (2026-08-14). Data as JSON: /api/errors/3a3162abc84deeec. Report an issue: GitHub.