{"record":{"id":"b5e83813642179c4","repo":"apache/flink","slug":"partition-sorting-does-not-support-type-yet","errorCode":null,"errorMessage":"Partition sorting does not support type {} yet.","messagePattern":"Partition sorting does not support type (.+?) yet\\.","errorType":"validation","errorClass":"UnsupportedOperationException","httpStatus":null,"severity":"error","filePath":"flink-core/src/main/java/org/apache/flink/api/common/operators/base/SortPartitionOperatorBase.java","lineNumber":84,"sourceCode":"    @Override\n    protected List<IN> executeOnCollections(\n            List<IN> inputData, RuntimeContext runtimeContext, ExecutionConfig executionConfig) {\n\n        TypeInformation<IN> inputType = getInput().getOperatorInfo().getOutputType();\n\n        int[] sortColumns = this.partitionOrdering.getFieldPositions();\n        boolean[] sortOrderings = this.partitionOrdering.getFieldSortDirections();\n\n        final TypeComparator<IN> sortComparator;\n        if (inputType instanceof CompositeType) {\n            sortComparator =\n                    ((CompositeType<IN>) inputType)\n                            .createComparator(sortColumns, sortOrderings, 0, executionConfig);\n        } else if (inputType instanceof AtomicType) {\n            sortComparator =\n                    ((AtomicType) inputType).createComparator(sortOrderings[0], executionConfig);\n        } else {\n            throw new UnsupportedOperationException(\n                    \"Partition sorting does not support type \" + inputType + \" yet.\");\n        }\n\n        Collections.sort(\n                inputData,\n                new Comparator<IN>() {\n                    @Override\n                    public int compare(IN o1, IN o2) {\n                        return sortComparator.compare(o1, o2);\n                    }\n                });\n\n        return inputData;\n    }\n}\n","sourceCodeStart":66,"sourceCodeEnd":100,"githubUrl":"https://github.com/apache/flink/blob/2f3c205e9266cb30240eb7f4fdab15cad629a70f/flink-core/src/main/java/org/apache/flink/api/common/operators/base/SortPartitionOperatorBase.java#L66-L100","documentation":"Thrown by SortPartitionOperatorBase.executeOnCollections when the input TypeInformation is neither CompositeType nor AtomicType, so no sort comparator can be built from the partition ordering's field positions. The unsupported input type is the one flowing into the sortPartition operator in the collection (local) execution path.","triggerScenarios":"Triggered at runtime when the operation fails because: Partition sorting does not support type the reported value yet.","commonSituations":"Commonly caused by misconfiguration, missing dependencies or files, unsupported types or operations, or invalid user input leading to: Partition sorting does not support type the reported value yet.","solutions":["Address the cause reported by the error message: Partition sorting does not support type the reported value yet.","Verify the inputs, configuration values, and classpath/dependency setup related to this operation, then retry."],"exampleFix":"Correct the condition described (\"Partition sorting does not support type the reported value yet.\") and rerun the job or command.","handlingStrategy":"type-guard","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"}