{"record":{"id":"a5337d2fa9a33e47","repo":"apache/seatunnel","slug":"unsupported-data-type-a5337d","errorCode":"UNSUPPORTED_DATA_TYPE","errorMessage":"Unsupported 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/sink/AmazonSqsSinkWriter.java","lineNumber":125,"sourceCode":"        MessageFormat format = config.get(FORMAT);\n        switch (format) {\n            case JSON:\n                return new JsonSerializationSchema(rowType);\n            case TEXT:\n                String delimiter = DEFAULT_FIELD_DELIMITER;\n                if (config.get(FIELD_DELIMITER) != null) {\n                    delimiter = config.get(FIELD_DELIMITER);\n                }\n                return TextSerializationSchema.builder()\n                        .seaTunnelRowType(rowType)\n                        .delimiter(delimiter)\n                        .build();\n            case CANAL_JSON:\n                return new CanalJsonSerializationSchema(rowType);\n            case DEBEZIUM_JSON:\n                return new DebeziumJsonSerializationSchema(rowType);\n            default:\n                throw new SeaTunnelJsonFormatException(\n                        CommonErrorCodeDeprecated.UNSUPPORTED_DATA_TYPE,\n                        \"Unsupported format: \" + format);\n        }\n    }\n}\n","sourceCodeStart":107,"sourceCodeEnd":131,"githubUrl":"https://github.com/apache/seatunnel/blob/cf67b549a7a6c35fa0beb12d83c62892427ea919/seatunnel-connectors-v2/connector-amazonsqs/src/main/java/org/apache/seatunnel/connectors/seatunnel/amazonsqs/sink/AmazonSqsSinkWriter.java#L107-L131","documentation":"AmazonSqsSinkWriter.createSerializationSchema builds the serialization schema from the configured format enum. If the format is not one of the supported cases (JSON, CANAL_JSON, DEBEZIUM_JSON), the default branch throws SeaTunnelJsonFormatException with code UNSUPPORTED_DATA_TYPE and message 'Unsupported format: <format>'.","triggerScenarios":"Configuring the SQS sink with a format value that parses to an enum constant outside the supported switch cases (typo, wrong-case entry, or a format this sink does not implement, e.g. csv or avro).","commonSituations":"Typo or unsupported format name in the sink config (format = jsonl, format = csv); copying a config from another connector that supports more formats; upgrading SeaTunnel and expecting a newly added format not yet supported by the SQS sink.","solutions":["Set format to one of the supported values: json, canal_json, or debezium_json (check the connector doc for exact option names/values).","Correct typos/casing in the format config option.","If a format like CSV is needed, serialize to the required format upstream or use a transform before the sink.","Check the SeaTunnel version's docs for the SQS sink's supported format list; upgrade only if a newer version adds the format."],"exampleFix":"// before\nformat = csv\n// after\nformat = json","handlingStrategy":"validation","validationCode":"Set<String> supported = Set.of(\"json\", \"canal_json\", \"debezium_json\");\nif (!supported.contains(config.get(\"format\"))) {\n    throw new IllegalArgumentException(\"format must be one of \" + supported);\n}","typeGuard":"null","tryCatchPattern":"try { writer = new AmazonSqsSinkWriter(...); } catch (SeaTunnelJsonFormatException e) { log.error(\"Bad format config: {}\", e.getMessage()); throw e; } // fail fast at job submit","preventionTips":["Only use formats documented for the SQS sink: json, canal_json, debezium_json.","Copy configs from the SQS sink docs, not other connectors.","Validate config values in CI before submitting jobs."],"tags":["java","sqs","format","config"],"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"}