{"record":{"id":"c5b7097f5e4e4d37","repo":"apache/flink","slug":"only-hadooppathbasedpendingfilerecoverable-is-supp","errorCode":null,"errorMessage":"Only HadoopPathBasedPendingFileRecoverable is supported.","messagePattern":"Only HadoopPathBasedPendingFileRecoverable is supported\\.","errorType":"exception","errorClass":"UnsupportedOperationException","httpStatus":null,"severity":"error","filePath":"flink-formats/flink-hadoop-bulk/src/main/java/org/apache/flink/formats/hadoop/bulk/HadoopPathBasedPartFileWriter.java","lineNumber":175,"sourceCode":"\n        static final HadoopPathBasedPendingFileRecoverableSerializer INSTANCE =\n                new HadoopPathBasedPendingFileRecoverableSerializer();\n\n        private static final Charset CHARSET = StandardCharsets.UTF_8;\n\n        private static final int MAGIC_NUMBER = 0x2c853c90;\n\n        @Override\n        public int getVersion() {\n            return 2;\n        }\n\n        @Override\n        public byte[] serialize(PendingFileRecoverable pendingFileRecoverable) {\n            if (!(pendingFileRecoverable\n                    instanceof\n                    HadoopPathBasedPartFileWriter.HadoopPathBasedPendingFileRecoverable)) {\n                throw new UnsupportedOperationException(\n                        \"Only HadoopPathBasedPendingFileRecoverable is supported.\");\n            }\n\n            HadoopPathBasedPendingFileRecoverable hadoopRecoverable =\n                    (HadoopPathBasedPendingFileRecoverable) pendingFileRecoverable;\n            Path path = hadoopRecoverable.getTargetFilePath();\n            Path inProgressPath = hadoopRecoverable.getTempFilePath();\n\n            byte[] pathBytes = path.toUri().toString().getBytes(CHARSET);\n            byte[] inProgressBytes = inProgressPath.toUri().toString().getBytes(CHARSET);\n\n            byte[] targetBytes =\n                    new byte[12 + pathBytes.length + inProgressBytes.length + Long.BYTES];\n            ByteBuffer bb = ByteBuffer.wrap(targetBytes).order(ByteOrder.LITTLE_ENDIAN);\n            bb.putInt(MAGIC_NUMBER);\n            bb.putInt(pathBytes.length);\n            bb.put(pathBytes);\n            bb.putInt(inProgressBytes.length);","sourceCodeStart":157,"sourceCodeEnd":193,"githubUrl":"https://github.com/apache/flink/blob/2f3c205e9266cb30240eb7f4fdab15cad629a70f/flink-formats/flink-hadoop-bulk/src/main/java/org/apache/flink/formats/hadoop/bulk/HadoopPathBasedPartFileWriter.java#L157-L193","documentation":"Error \"Only HadoopPathBasedPendingFileRecoverable is supported.\" thrown in apache/flink.","triggerScenarios":"Triggered at runtime when the operation fails because: Only HadoopPathBasedPendingFileRecoverable is supported.","commonSituations":"Commonly caused by misconfiguration, missing dependencies or files, unsupported types or operations, or invalid user input leading to: Only HadoopPathBasedPendingFileRecoverable is supported.","solutions":["Address the cause reported by the error message: Only HadoopPathBasedPendingFileRecoverable is supported.","Verify the inputs, configuration values, and classpath/dependency setup related to this operation, then retry."],"exampleFix":"Correct the condition described (\"Only HadoopPathBasedPendingFileRecoverable is supported.\") and rerun the job or command.","handlingStrategy":null,"validationCode":null,"typeGuard":null,"tryCatchPattern":null,"preventionTips":[],"tags":[],"backgroundTag":null,"analyzedSha":"2f3c205e9266cb30240eb7f4fdab15cad629a70f","analyzedAt":"2026-08-14T08:48:24.518Z","schemaVersion":2},"datasetVersion":"2026-08-14T10:17:34.591Z"}