{"record":{"id":"2f5def95192efd77","repo":"apache/flink","slug":"unsupported-type-in-node","errorCode":null,"errorMessage":"Unsupported type '{}' in node: {}","messagePattern":"Unsupported type '(.+?)' in node: (.+?)","errorType":"validation","errorClass":"java.lang.IllegalArgumentException","httpStatus":null,"severity":"error","filePath":"flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowSchemaConverter.java","lineNumber":180,"sourceCode":"                            typeSet.add(Types.STRING);\n                        }\n                        break;\n                    case TYPE_NUMBER:\n                        typeSet.add(Types.BIG_DEC);\n                        break;\n                    case TYPE_INTEGER:\n                        // use BigDecimal for easier interoperability\n                        // without affecting the correctness of the result\n                        typeSet.add(Types.BIG_DEC);\n                        break;\n                    case TYPE_OBJECT:\n                        typeSet.add(convertObject(location, node, root));\n                        break;\n                    case TYPE_ARRAY:\n                        typeSet.add(convertArray(location, node, root));\n                        break;\n                    default:\n                        throw new IllegalArgumentException(\n                                \"Unsupported type '\"\n                                        + node.get(TYPE).asText()\n                                        + \"' in node: \"\n                                        + location);\n                }\n            }\n        }\n        // use TYPE of reference as fallback if present\n        else {\n            ref.filter(r -> r.has(TYPE))\n                    .ifPresent(r -> typeSet.add(convertType(node.get(REF).asText(), r, root)));\n        }\n\n        // simple interpretation of ONE_OF for supporting \"object or null\"\n        if (node.has(ONE_OF) && node.get(ONE_OF).isArray()) {\n            final TypeInformation<?>[] types =\n                    convertTypes(location + '/' + ONE_OF, node.get(ONE_OF), root);\n            typeSet.addAll(Arrays.asList(types));","sourceCodeStart":162,"sourceCodeEnd":198,"githubUrl":"https://github.com/apache/flink/blob/2f3c205e9266cb30240eb7f4fdab15cad629a70f/flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowSchemaConverter.java#L162-L198","documentation":"Indicates the JSON schema node at the given location declares a type keyword (e.g. 'bool', 'null', or an unrecognized value) that the converter has no mapping for in its switch. The offending type string and full node content identify exactly which schema entry is unsupported.","triggerScenarios":"Triggered at runtime when the operation fails because: Unsupported type 'the reported value' in node: the reported value.","commonSituations":"Commonly caused by misconfiguration, missing dependencies or files, unsupported types or operations, or invalid user input leading to: Unsupported type 'the reported value' in node: the reported value.","solutions":["Address the cause reported by the error message: Unsupported type 'the reported value' in node: the reported value","Verify the inputs, configuration values, and classpath/dependency setup related to this operation, then retry."],"exampleFix":"Correct the condition described (\"Unsupported type 'the reported value' in node: the reported value\") and rerun the job or command.","handlingStrategy":"validation","validationCode":null,"typeGuard":null,"tryCatchPattern":null,"preventionTips":[],"tags":[],"backgroundTag":null,"analyzedSha":"2f3c205e9266cb30240eb7f4fdab15cad629a70f","analyzedAt":"2026-08-14T08:48:24.518Z","contentChangedAt":"2026-08-14T08:48:24.518Z","schemaVersion":2},"datasetVersion":"2026-09-23T08:17:48.524Z"}