apache/flink · error · FlinkRuntimeException

The Accumulators cannot be fetched through the Job Client…

Error message

The Accumulators cannot be fetched through the Job Client when in Web Submission.

What it means

WebSubmissionJobClient's accumulator/request methods unconditionally throw FlinkRuntimeException: the web-submission client keeps only a JobID with no attachment to the cluster, so accumulator results cannot be fetched. A sentinel guard — the operation is unsupported in this mode rather than failing at runtime for an environmental reason.

Solutions

1. Address the cause reported by the error message: The Accumulators cannot be fetched through the Job Client when in Web Submission.
2. Verify the inputs, configuration values, and classpath/dependency setup related to this operation, then retry.

Example fix

Correct the condition described ("The Accumulators cannot be fetched through the Job Client when in Web Submission.") and rerun the job or command.

When it happens

Trigger: Triggered at runtime when the operation fails because: The Accumulators cannot be fetched through the Job Client when in Web Submission.

Common situations: Commonly caused by misconfiguration, missing dependencies or files, unsupported types or operations, or invalid user input leading to: The Accumulators cannot be fetched through the Job Client when in Web Submission.

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

Appendix: source

Thrown at flink-clients/src/main/java/org/apache/flink/client/deployment/application/WebSubmissionJobClient.java:86

    @Override
    public CompletableFuture<String> stopWithSavepoint(
            boolean advanceToEndOfEventTime,
            @Nullable String savepointDirectory,
            SavepointFormatType formatType) {
        throw new FlinkRuntimeException(
                "Stop with Savepoint is not supported by the Job Client when in Web Submission.");
    }

    @Override
    public CompletableFuture<String> triggerSavepoint(
            @Nullable String savepointDirectory, SavepointFormatType formatType) {
        throw new FlinkRuntimeException(
                "A savepoint cannot be taken through the Job Client when in Web Submission.");
    }

    @Override
    public CompletableFuture<Map<String, Object>> getAccumulators() {
        throw new FlinkRuntimeException(
                "The Accumulators cannot be fetched through the Job Client when in Web Submission.");
    }

    @Override
    public CompletableFuture<JobExecutionResult> getJobExecutionResult() {
        throw new FlinkRuntimeException(
                "The Job Result cannot be fetched through the Job Client when in Web Submission.");
    }
}

View on GitHub (pinned to 2f3c205e92)