apache/flink · error · IOException

Interrupted while waiting for part uploads to complete

Error message

Interrupted while waiting for part uploads to complete

What it means

Error "Interrupted while waiting for part uploads to complete" 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:236

    private void awaitPendingPartsUpload() throws IOException {
        checkState(currentUploadInfo.getRemainingParts() == uploadsInProgress.size());

        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);

View on GitHub (pinned to 2f3c205e92)

Solutions

1. Address the cause reported by the error message: Interrupted while waiting for part uploads to complete
2. Verify the inputs, configuration values, and classpath/dependency setup related to this operation, then retry.

Example fix

Correct the condition described ("Interrupted while waiting for part uploads to complete") and rerun the job or command.

When it happens

Trigger: Triggered at runtime when the operation fails because: Interrupted while waiting for part uploads to complete.

Common situations: Commonly caused by misconfiguration, missing dependencies or files, unsupported types or operations, or invalid user input leading to: Interrupted while waiting for part uploads to complete.

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