{"record":{"id":"908c766f5697d31c","repo":"apache/flink","slug":"can-not-find-format-factory-908c76","errorCode":null,"errorMessage":"Can not find format factory.","messagePattern":"Can not find format factory\\.","errorType":"exception","errorClass":"TableException","httpStatus":null,"severity":"error","filePath":"flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/table/FileSystemTableSource.java","lineNumber":223,"sourceCode":"                        new ProjectingBulkFormat(\n                                new DeserializationSchemaAdapter(\n                                        deserializationFormat.createRuntimeDecoder(\n                                                scanContext, physicalDataType)),\n                                physicalProjections.toTopLevelIndexes(),\n                                scanContext.createTypeInformation(\n                                        physicalProjections.project(physicalDataType)));\n            }\n\n            format =\n                    wrapBulkFormat(\n                            scanContext,\n                            format,\n                            producedDataType,\n                            metadataToExtract,\n                            partitionKeysToExtract);\n            return createSourceProvider(format);\n        } else {\n            throw new TableException(\"Can not find format factory.\");\n        }\n    }\n\n    /**\n     * Wraps bulk format in a {@link FileInfoExtractorBulkFormat} and {@link LimitableBulkFormat},\n     * if needed.\n     */\n    private BulkFormat<RowData, FileSourceSplit> wrapBulkFormat(\n            ScanContext context,\n            BulkFormat<RowData, FileSourceSplit> bulkFormat,\n            DataType producedDataType,\n            List<ReadableFileInfo> metadata,\n            List<String> partitionKeys) {\n        if (!metadata.isEmpty() || !partitionKeys.isEmpty()) {\n            final List<String> producedFieldNames = DataType.getFieldNames(producedDataType);\n            final Map<String, FileInfoAccessor> metadataColumns =\n                    IntStream.range(0, metadata.size())\n                            .mapToObj(","sourceCodeStart":205,"sourceCodeEnd":241,"githubUrl":"https://github.com/apache/flink/blob/2f3c205e9266cb30240eb7f4fdab15cad629a70f/flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/table/FileSystemTableSource.java#L205-L241","documentation":"Error \"Can not find format factory.\" thrown in apache/flink.","triggerScenarios":"Triggered at runtime when the operation fails because: Can not find format factory.","commonSituations":"Commonly caused by misconfiguration, missing dependencies or files, unsupported types or operations, or invalid user input leading to: Can not find format factory.","solutions":["Address the cause reported by the error message: Can not find format factory.","Verify the inputs, configuration values, and classpath/dependency setup related to this operation, then retry."],"exampleFix":"Correct the condition described (\"Can not find format factory.\") 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"}