{"record":{"id":"693f6c2c12b316c9","repo":"apache/seatunnel","slug":"csv-file-does-not-support-this-compress-type-693f6c","errorCode":null,"errorMessage":"Csv file does not support this compress type: {}","messagePattern":"Csv file does not support this compress type: (.+?)","errorType":"console","errorClass":null,"httpStatus":null,"severity":"warning","filePath":"seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/source/reader/CsvReadStrategy.java","lineNumber":191,"sourceCode":"            throw new FileConnectorException(\n                    FileConnectorErrorCode.DATA_DESERIALIZE_FAILED, errorMsg, e);\n        }\n    }\n\n    private InputStream wrapInputStream(InputStream inputStream, FileSourceSplit split)\n            throws IOException {\n        InputStream resultStream;\n        // process compression isnputStream\n        switch (compressFormat) {\n            case LZO:\n                LzopCodec lzo = new LzopCodec();\n                resultStream = lzo.createInputStream(inputStream);\n                break;\n            case NONE:\n                resultStream = inputStream;\n                break;\n            default:\n                log.warn(\n                        \"Csv file does not support this compress type: {}\",\n                        compressFormat.getCompressCodec());\n                resultStream = inputStream;\n                break;\n        }\n        // rebuild inputStream\n        if (isSplitReadEnabled(split)) {\n            resultStream = safeSlice(resultStream, split.getStart(), split.getLength());\n        }\n        return resultStream;\n    }\n\n    private boolean isSplitReadEnabled(FileSourceSplit split) {\n        return enableSplitFile && split.getLength() > -1;\n    }\n\n    private CSVFormat getCSVFormat(FileSourceSplit split) {\n        String quoteChar = readonlyConfig.get(FileBaseSourceOptions.QUOTE_CHAR);","sourceCodeStart":173,"sourceCodeEnd":209,"githubUrl":"https://github.com/apache/seatunnel/blob/cf67b549a7a6c35fa0beb12d83c62892427ea919/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/source/reader/CsvReadStrategy.java#L173-L209","documentation":"Warning logged by CsvReadStrategy.wrapInputStream when the configured compress_codec cannot be handled for CSV reading. Unknown/unsupported CompressFormat values fall through the switch's default branch; the raw (still-compressed) input stream is used as-is, which usually causes downstream parse garbage rather than a hard failure.","triggerScenarios":"compress_codec set to a value whose CompressFormat has no case in the CSV switch (anything other than LZO/LZ4/GZIP/BZIP2/NONE handled branches) — e.g. a codec added for other formats but not wired into the CSV reader, or a typo mapping to an unexpected enum default.","commonSituations":"Users setting compress_codec = zip or snappy for CSV where the CSV reader only supports a fixed set; config copied from a JSON/ORC source example that supports more codecs; upgraded enum values not yet supported by CSV path.","solutions":["Set compress_codec to a CSV-supported value: none, gzip, bzip2, lz4, or lzo (verify supported list in docs for your version).","Decompress the files beforehand and read them uncompressed (compress_codec = none).","If the codec is genuinely needed (e.g. snappy), pre-convert files to a supported compression or a different file_format_type that supports it.","Check for typos in the compress_codec config value."],"exampleFix":"// before\ncompress_codec = \"snappy\"\n// after\ncompress_codec = \"gzip\"  # or none/pre-decompress","handlingStrategy":"validation","validationCode":"Set<String> csvSupported = Set.of(\"none\",\"gzip\",\"bzip2\",\"lz4\",\"lzo\");\nif (!csvSupported.contains(config.getString(\"compress_codec\"))) {\n    throw new IllegalArgumentException(\"compress_codec not supported by CSV reader\");\n}","typeGuard":null,"tryCatchPattern":null,"preventionTips":["Verify the compress_codec allowed values for the CSV reader in your version's docs.","Pre-decompress unsupported codecs before ingestion.","Don't copy compress_codec values from other file-format configs blindly."],"tags":["csv","compression","config","unsupported-codec"],"backgroundTag":"unsupported-enum-value","analyzedSha":"cf67b549a7a6c35fa0beb12d83c62892427ea919","analyzedAt":"2026-09-10T21:44:55.265Z","contentChangedAt":"2026-09-10T21:44:55.265Z","schemaVersion":2},"datasetVersion":"2026-09-23T08:17:48.524Z"}