{"record":{"id":"519363b601fa7ff5","repo":"apache/seatunnel","slug":"unsupported-data-type-519363","errorCode":"UNSUPPORTED_DATA_TYPE","errorMessage":"Unsupported format: ${format}","messagePattern":"Unsupported format: (.+?)","errorType":"error_code","errorClass":"SeaTunnelJsonFormatException","httpStatus":null,"severity":"error","filePath":"seatunnel-connectors-v2/connector-amazonsqs/src/main/java/org/apache/seatunnel/connectors/seatunnel/amazonsqs/source/AmazonSqsSourceFactory.java","lineNumber":143,"sourceCode":"                                .delimiter(delimiter)\n                                .build();\n                break;\n            case CANAL_JSON:\n                deserializationSchema =\n                        CanalJsonDeserializationSchema.builder(catalogTable)\n                                .setIgnoreParseErrors(false)\n                                .build();\n                break;\n            case DEBEZIUM_JSON:\n                boolean includeSchema = DEBEZIUM_RECORD_INCLUDE_SCHEMA.defaultValue();\n                if (config.hasPath(DEBEZIUM_RECORD_INCLUDE_SCHEMA.key())) {\n                    includeSchema = config.getBoolean(DEBEZIUM_RECORD_INCLUDE_SCHEMA.key());\n                }\n                deserializationSchema =\n                        new DebeziumJsonDeserializationSchema(catalogTable, false, includeSchema);\n                break;\n            default:\n                throw new SeaTunnelJsonFormatException(\n                        CommonErrorCodeDeprecated.UNSUPPORTED_DATA_TYPE,\n                        \"Unsupported format: \" + format);\n        }\n        return deserializationSchema;\n    }\n}\n","sourceCodeStart":125,"sourceCodeEnd":150,"githubUrl":"https://github.com/apache/seatunnel/blob/cf67b549a7a6c35fa0beb12d83c62892427ea919/seatunnel-connectors-v2/connector-amazonsqs/src/main/java/org/apache/seatunnel/connectors/seatunnel/amazonsqs/source/AmazonSqsSourceFactory.java#L125-L150","documentation":"Amazon SQS source factory builds a deserialization schema from the user-configured 'format' option. The switch over supported formats (JSON, CANAL_JSON, DEBEZIUM_JSON, etc.) has no matching case, so it throws SeaTunnelJsonFormatException with UNSUPPORTED_DATA_TYPE. The format string itself is never echoed into the message, so check your config value directly.","triggerScenarios":"Setting format = <value> in an AmazonSqs source config where <value> is not one of the formats handled by the switch in AmazonSqsSourceFactory.deserializationSchema (e.g. a typo like 'json' vs 'JSON' handling, or an unsupported format like 'avro').","commonSituations":"Typo in the format HOCON key value; copying a format from another connector that supports more formats (e.g. avro, protobuf); using a format added only in newer SeaTunnel versions while running an older connector build.","solutions":["Check the format value in the source config against formats supported by connector-amazonsqs (see AmazonSqsSourceFactory option definition)","Fix spelling/casing of the format value in the job config","Upgrade SeaTunnel if the desired format is supported only in a newer version","Implement an extra case in deserializationSchema if adding a new format via a custom build"],"exampleFix":"// before\nformat = avro\n// after\nformat = json","handlingStrategy":"validation","validationCode":"// before submitting job\nList<String> supported = List.of(\"json\", \"canal-json\", \"debezium-json\");\nif (!supported.contains(config.getString(\"format\").toLowerCase())) {\n    throw new IllegalArgumentException(\"format must be one of \" + supported);\n}","typeGuard":null,"tryCatchPattern":null,"preventionTips":["Copy format values only from the connector's documented option list","Validate job config with the connector's Option definitions before submission","Pin SeaTunnel version and check format support in that version's docs"],"tags":["format","config","deserialization"],"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-14T05:17:10.506Z"}