apache/flink · error · UnsupportedOperationException

Unsupported input message: %s

Error message

Unsupported input message: %s

What it means

Error "Unsupported input message: %s" thrown in apache/flink.

Source

Thrown at flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/table/batch/compact/BatchCompactCoordinator.java:91

    @Override
    public void open() throws Exception {
        fs = fsFactory.get();
        inputFiles = new HashMap<>();
        element = new StreamRecord<>(null);
    }

    @Override
    public void processElement(StreamRecord<CoordinatorInput> element) throws Exception {
        CoordinatorInput coordinatorInput = element.getValue();
        if (coordinatorInput instanceof InputFile) {
            InputFile file = (InputFile) coordinatorInput;
            // collect the written files
            inputFiles
                    .computeIfAbsent(file.getPartition(), k -> new ArrayList<>())
                    .add(file.getFile());
        } else {
            throw new UnsupportedOperationException(
                    "Unsupported input message: " + coordinatorInput);
        }
    }

    @Override
    public void endInput() throws Exception {
        for (Map.Entry<String, List<Path>> partitionFiles : inputFiles.entrySet()) {
            compactPartitionFiles(partitionFiles.getKey(), partitionFiles.getValue());
        }
    }

    @Override
    public void close() throws Exception {
        inputFiles.clear();
    }

    private void compactPartitionFiles(String partition, List<Path> paths) throws IOException {
        if (paths.isEmpty()) {

View on GitHub (pinned to 2f3c205e92)

Solutions

1. Address the cause reported by the error message: Unsupported input message: 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 ("Unsupported input message: the reported value") and rerun the job or command.

When it happens

Trigger: Triggered at runtime when the operation fails because: Unsupported input message: the reported value.

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

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