apache/flink · error · IOException

interrupted

Error message

interrupted

What it means

Error "interrupted" thrown in apache/flink.

Source

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

    private void closeAndUploadPart() throws IOException {
        fileStream.flush();
        fileStream.close();
        if (fileStream.getPos() > 0L) {
            upload.uploadPart(fileStream);
        }
        fileStream.release();
    }

    // ------------------------------------------------------------------------
    //  locking
    // ------------------------------------------------------------------------

    private void lock() throws IOException {
        try {
            lock.lockInterruptibly();
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
            throw new IOException("interrupted");
        }
    }

    private void unlock() {
        lock.unlock();
    }

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

    public static S3RecoverableFsDataOutputStream newStream(
            final RecoverableMultiPartUpload upload,
            final FunctionWithException<File, RefCountedFileWithStream, IOException> tmpFileCreator,
            final long userDefinedMinPartSize)
            throws IOException {

        checkArgument(userDefinedMinPartSize >= S3_MULTIPART_MIN_PART_SIZE);

View on GitHub (pinned to 2f3c205e92)

Solutions

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

Example fix

Correct the condition described ("interrupted") and rerun the job or command.

When it happens

Trigger: Triggered at runtime when the operation fails because: interrupted.

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

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