apache/flink · error · TableException

Can not find format factory.

Error message

Can not find format factory.

What it means

Error "Can not find format factory." thrown in apache/flink.

Source

Thrown at flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/table/FileSystemTableSource.java:223

                        new ProjectingBulkFormat(
                                new DeserializationSchemaAdapter(
                                        deserializationFormat.createRuntimeDecoder(
                                                scanContext, physicalDataType)),
                                physicalProjections.toTopLevelIndexes(),
                                scanContext.createTypeInformation(
                                        physicalProjections.project(physicalDataType)));
            }

            format =
                    wrapBulkFormat(
                            scanContext,
                            format,
                            producedDataType,
                            metadataToExtract,
                            partitionKeysToExtract);
            return createSourceProvider(format);
        } else {
            throw new TableException("Can not find format factory.");
        }
    }

    /**
     * Wraps bulk format in a {@link FileInfoExtractorBulkFormat} and {@link LimitableBulkFormat},
     * if needed.
     */
    private BulkFormat<RowData, FileSourceSplit> wrapBulkFormat(
            ScanContext context,
            BulkFormat<RowData, FileSourceSplit> bulkFormat,
            DataType producedDataType,
            List<ReadableFileInfo> metadata,
            List<String> partitionKeys) {
        if (!metadata.isEmpty() || !partitionKeys.isEmpty()) {
            final List<String> producedFieldNames = DataType.getFieldNames(producedDataType);
            final Map<String, FileInfoAccessor> metadataColumns =
                    IntStream.range(0, metadata.size())
                            .mapToObj(

View on GitHub (pinned to 2f3c205e92)

Solutions

1. Address the cause reported by the error message: Can not find format factory.
2. Verify the inputs, configuration values, and classpath/dependency setup related to this operation, then retry.

Example fix

Correct the condition described ("Can not find format factory.") and rerun the job or command.

When it happens

Trigger: Triggered at runtime when the operation fails because: Can not find format factory.

Common situations: Commonly caused by misconfiguration, missing dependencies or files, unsupported types or operations, or invalid user input leading to: Can not find format factory.

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