apache/flink · error · IllegalConfigurationException

Unknown retry policy: {}

Error message

Unknown retry policy: {}

What it means

Error "Unknown retry policy: {}" thrown in apache/flink.

Source

Thrown at flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/RetryPolicy.java:40

import org.apache.flink.configuration.ReadableConfig;

import java.io.IOException;
import java.util.concurrent.TimeoutException;

/** Retry policy to use by {@link RetryingExecutor}. */
@Internal
public interface RetryPolicy {
    static RetryPolicy fromConfig(ReadableConfig config) {
        switch (config.get(FsStateChangelogOptions.RETRY_POLICY)) {
            case "fixed":
                return fixed(
                        config.get(FsStateChangelogOptions.RETRY_MAX_ATTEMPTS),
                        config.get(FsStateChangelogOptions.UPLOAD_TIMEOUT).toMillis(),
                        config.get(FsStateChangelogOptions.RETRY_DELAY_AFTER_FAILURE).toMillis());
            case "none":
                return NONE;
            default:
                throw new IllegalConfigurationException(
                        "Unknown retry policy: "
                                + config.get(FsStateChangelogOptions.RETRY_POLICY));
        }
    }

    /**
     * @return timeout in millis. Zero or negative means no timeout.
     */
    long timeoutFor(int attempt);

    /**
     * @return delay in millis before the next attempt. Negative means no retry, zero means no
     *     delay.
     */
    long retryAfter(int failedAttempt, Exception exception);

    RetryPolicy NONE =
            new RetryPolicy() {

View on GitHub (pinned to 2f3c205e92)

Solutions

1. Address the cause reported by the error message: Unknown retry policy: the reported value
2. Verify the inputs, configuration values, and classpath/dependency setup related to this operation, then retry.

Example fix

Correct the condition described ("Unknown retry policy: the reported value") and rerun the job or command.

When it happens

Trigger: Triggered at runtime when the operation fails because: Unknown retry policy: the reported value.

Common situations: Commonly caused by misconfiguration, missing dependencies or files, unsupported types or operations, or invalid user input leading to: Unknown retry policy: the reported value.

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