{"record":{"id":"0324e1736fc26ebe","repo":"apache/flink","slug":"interrupted-0324e1","errorCode":null,"errorMessage":"interrupted","messagePattern":"interrupted","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/S3RecoverableFsDataOutputStream.java","lineNumber":225,"sourceCode":"    private void closeAndUploadPart() throws IOException {\n        fileStream.flush();\n        fileStream.close();\n        if (fileStream.getPos() > 0L) {\n            upload.uploadPart(fileStream);\n        }\n        fileStream.release();\n    }\n\n    // ------------------------------------------------------------------------\n    //  locking\n    // ------------------------------------------------------------------------\n\n    private void lock() throws IOException {\n        try {\n            lock.lockInterruptibly();\n        } catch (InterruptedException e) {\n            Thread.currentThread().interrupt();\n            throw new IOException(\"interrupted\");\n        }\n    }\n\n    private void unlock() {\n        lock.unlock();\n    }\n\n    // ------------------------------------------------------------------------\n    //  factory methods\n    // ------------------------------------------------------------------------\n\n    public static S3RecoverableFsDataOutputStream newStream(\n            final RecoverableMultiPartUpload upload,\n            final FunctionWithException<File, RefCountedFileWithStream, IOException> tmpFileCreator,\n            final long userDefinedMinPartSize)\n            throws IOException {\n\n        checkArgument(userDefinedMinPartSize >= S3_MULTIPART_MIN_PART_SIZE);","sourceCodeStart":207,"sourceCodeEnd":243,"githubUrl":"https://github.com/apache/flink/blob/2f3c205e9266cb30240eb7f4fdab15cad629a70f/flink-filesystems/flink-s3-fs-base/src/main/java/org/apache/flink/fs/s3/common/writer/S3RecoverableFsDataOutputStream.java#L207-L243","documentation":"Error \"interrupted\" thrown in apache/flink.","triggerScenarios":"Triggered at runtime when the operation fails because: interrupted.","commonSituations":"Commonly caused by misconfiguration, missing dependencies or files, unsupported types or operations, or invalid user input leading to: interrupted.","solutions":["Address the cause reported by the error message: interrupted","Verify the inputs, configuration values, and classpath/dependency setup related to this operation, then retry."],"exampleFix":"Correct the condition described (\"interrupted\") 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"}