{"record":{"id":"128fb52e6edc8406","repo":"apache/flink","slug":"uploading-parts-failed-128fb5","errorCode":null,"errorMessage":"Uploading parts failed","messagePattern":"Uploading parts failed","errorType":"exception","errorClass":"IOException","httpStatus":null,"severity":"error","filePath":"flink-filesystems/flink-s3-fs-base/src/main/java/org/apache/flink/fs/s3/common/writer/RecoverableMultiPartUploadImpl.java","lineNumber":238,"sourceCode":"\n        while (currentUploadInfo.getRemainingParts() > 0) {\n            CompletableFuture<PartETag> next = uploadsInProgress.peekFirst();\n            PartETag nextPart = awaitPendingPartUploadToComplete(next);\n            currentUploadInfo.registerCompletePart(nextPart);\n            uploadsInProgress.removeFirst();\n        }\n    }\n\n    private PartETag awaitPendingPartUploadToComplete(CompletableFuture<PartETag> upload)\n            throws IOException {\n        final PartETag completedUploadEtag;\n        try {\n            completedUploadEtag = upload.get();\n        } catch (InterruptedException e) {\n            Thread.currentThread().interrupt();\n            throw new IOException(\"Interrupted while waiting for part uploads to complete\");\n        } catch (ExecutionException e) {\n            throw new IOException(\"Uploading parts failed\", e.getCause());\n        }\n        return completedUploadEtag;\n    }\n\n    // ------------------------------------------------------------------------\n    //  factory methods\n    // ------------------------------------------------------------------------\n\n    public static RecoverableMultiPartUploadImpl newUpload(\n            final S3AccessHelper s3AccessHelper,\n            final Executor uploadThreadPool,\n            final String objectName)\n            throws IOException {\n\n        final String multiPartUploadId = s3AccessHelper.startMultiPartUpload(objectName);\n\n        return new RecoverableMultiPartUploadImpl(\n                s3AccessHelper,","sourceCodeStart":220,"sourceCodeEnd":256,"githubUrl":"https://github.com/apache/flink/blob/2f3c205e9266cb30240eb7f4fdab15cad629a70f/flink-filesystems/flink-s3-fs-base/src/main/java/org/apache/flink/fs/s3/common/writer/RecoverableMultiPartUploadImpl.java#L220-L256","documentation":"Error \"Uploading parts failed\" thrown in apache/flink.","triggerScenarios":"Triggered at runtime when the operation fails because: Uploading parts failed.","commonSituations":"Commonly caused by misconfiguration, missing dependencies or files, unsupported types or operations, or invalid user input leading to: Uploading parts failed.","solutions":["Address the cause reported by the error message: Uploading parts failed","Verify the inputs, configuration values, and classpath/dependency setup related to this operation, then retry."],"exampleFix":"Correct the condition described (\"Uploading parts failed\") 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"}