apache/flink · error · IOException

Uploading parts failed

Error message

Uploading parts failed

What it means

Error "Uploading parts failed" thrown in apache/flink.

Source

Thrown at flink-filesystems/flink-s3-fs-base/src/main/java/org/apache/flink/fs/s3/common/writer/RecoverableMultiPartUploadImpl.java:238

        while (currentUploadInfo.getRemainingParts() > 0) {
            CompletableFuture<PartETag> next = uploadsInProgress.peekFirst();
            PartETag nextPart = awaitPendingPartUploadToComplete(next);
            currentUploadInfo.registerCompletePart(nextPart);
            uploadsInProgress.removeFirst();
        }
    }

    private PartETag awaitPendingPartUploadToComplete(CompletableFuture<PartETag> upload)
            throws IOException {
        final PartETag completedUploadEtag;
        try {
            completedUploadEtag = upload.get();
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
            throw new IOException("Interrupted while waiting for part uploads to complete");
        } catch (ExecutionException e) {
            throw new IOException("Uploading parts failed", e.getCause());
        }
        return completedUploadEtag;
    }

    // ------------------------------------------------------------------------
    //  factory methods
    // ------------------------------------------------------------------------

    public static RecoverableMultiPartUploadImpl newUpload(
            final S3AccessHelper s3AccessHelper,
            final Executor uploadThreadPool,
            final String objectName)
            throws IOException {

        final String multiPartUploadId = s3AccessHelper.startMultiPartUpload(objectName);

        return new RecoverableMultiPartUploadImpl(
                s3AccessHelper,

View on GitHub (pinned to 2f3c205e92)

Solutions

1. Address the cause reported by the error message: Uploading parts failed
2. Verify the inputs, configuration values, and classpath/dependency setup related to this operation, then retry.

Example fix

Correct the condition described ("Uploading parts failed") and rerun the job or command.

When it happens

Trigger: Triggered at runtime when the operation fails because: Uploading parts failed.

Common situations: Commonly caused by misconfiguration, missing dependencies or files, unsupported types or operations, or invalid user input leading to: Uploading parts failed.

AI-assisted analysis of apache/flink@2f3c205e92 (2026-08-14). Data as JSON: /api/errors/128fb52e6edc8406. Report an issue: GitHub.