{"record":{"id":"3a3162abc84deeec","repo":"apache/flink","slug":"base-job-id-s-is-not-found-in-the-recovered-jobs","errorCode":null,"errorMessage":"Base job ID %s is not found in the recovered jobs.","messagePattern":"Base job ID (.+?) is not found in the recovered jobs\\.","errorType":"validation","errorClass":"IllegalArgumentException","httpStatus":null,"severity":"error","filePath":"flink-clients/src/main/java/org/apache/flink/client/program/JobNameBasedJobIdManager.java","lineNumber":85,"sourceCode":"     * Creates a new job ID manager with the given base job ID and recovered job information.\n     *\n     * @param baseJobId the base job ID used as the origin for deriving all job IDs\n     * @param allRecoveredJobInfos a collection of recovered job information; if non-empty, it\n     *     <b>must contain</b> a job with ID equal to {@code baseJobId}\n     */\n    public JobNameBasedJobIdManager(JobID baseJobId, Collection<JobInfo> allRecoveredJobInfos) {\n        this.baseJobId = checkNotNull(baseJobId);\n        checkNotNull(allRecoveredJobInfos);\n\n        if (!allRecoveredJobInfos.isEmpty()) {\n            // step 1: find the first job name\n            Optional<JobInfo> optionalBaseJobInfo =\n                    allRecoveredJobInfos.stream()\n                            .filter(jobInfo -> jobInfo.getJobId().equals(baseJobId))\n                            .findFirst();\n\n            if (optionalBaseJobInfo.isEmpty()) {\n                throw new IllegalArgumentException(\n                        String.format(\n                                \"Base job ID %s is not found in the recovered jobs.\", baseJobId));\n            }\n\n            this.firstJobName = optionalBaseJobInfo.get().getJobName();\n\n            // step 2: group jobs by job name and sort then according to the job index\n            Map<String, List<JobID>> grouped =\n                    allRecoveredJobInfos.stream()\n                            .collect(\n                                    Collectors.groupingBy(\n                                            JobInfo::getJobName,\n                                            Collectors.mapping(\n                                                    JobInfo::getJobId, Collectors.toList())));\n\n            for (Map.Entry<String, List<JobID>> entry : grouped.entrySet()) {\n                String jobName = entry.getKey();\n                List<JobID> jobIds = entry.getValue();","sourceCodeStart":67,"sourceCodeEnd":103,"githubUrl":"https://github.com/apache/flink/blob/2f3c205e9266cb30240eb7f4fdab15cad629a70f/flink-clients/src/main/java/org/apache/flink/client/program/JobNameBasedJobIdManager.java#L67-L103","documentation":"Error \"Base job ID %s is not found in the recovered jobs.\" thrown in apache/flink.","triggerScenarios":"Triggered at runtime when the operation fails because: Base job ID the reported value is not found in the recovered jobs.","commonSituations":"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.","solutions":["Address the cause reported by the error message: Base job ID the reported value is not found in the recovered jobs.","Verify the inputs, configuration values, and classpath/dependency setup related to this operation, then retry."],"exampleFix":"Correct the condition described (\"Base job ID the reported value is not found in the recovered jobs.\") and rerun the job or command.","handlingStrategy":null,"validationCode":null,"typeGuard":null,"tryCatchPattern":null,"preventionTips":[],"tags":[],"backgroundTag":null,"analyzedSha":"2f3c205e9266cb30240eb7f4fdab15cad629a70f","analyzedAt":"2026-08-14T08:48:24.518Z","schemaVersion":2},"datasetVersion":"2026-08-14T10:17:34.591Z"}