{"record":{"id":"444b18d6abdfa54b","repo":"apache/beam","slug":"error-closing-flightstream","errorCode":null,"errorMessage":"Error closing FlightStream","messagePattern":"Error closing FlightStream","errorType":"console","errorClass":null,"httpStatus":null,"severity":"error","filePath":"sdks/java/io/arrow-flight/src/main/java/org/apache/beam/sdk/io/arrowflight/ArrowFlightIO.java","lineNumber":489,"sourceCode":"        } else {\n          return false;\n        }\n      }\n    }\n\n    @Override\n    public Row getCurrent() {\n      return current;\n    }\n\n    @Override\n    public void close() throws IOException {\n      try {\n        if (stream != null) {\n          stream.close();\n        }\n      } catch (Exception e) {\n        LOG.warn(\"Error closing FlightStream\", e);\n      }\n      try {\n        if (client != null) {\n          client.close();\n        }\n      } catch (InterruptedException e) {\n        Thread.currentThread().interrupt();\n        LOG.warn(\"Interrupted closing FlightClient\", e);\n      }\n      try {\n        if (allocator != null) {\n          allocator.close();\n        }\n      } catch (Exception e) {\n        LOG.warn(\"Error closing BufferAllocator\", e);\n      }\n    }\n","sourceCodeStart":471,"sourceCodeEnd":507,"githubUrl":"https://github.com/apache/beam/blob/12126d8942aaf848030c478b4c6a28c6af861c66/sdks/java/io/arrow-flight/src/main/java/org/apache/beam/sdk/io/arrowflight/ArrowFlightIO.java#L471-L507","documentation":"WARN logged in ArrowFlightIO reader's close(): closing the Arrow FlightStream raised an exception. The close path deliberately swallows the error (after logging) so that resource cleanup continues to the client and allocator teardown — a failure while releasing the read stream does not mask or abort the rest of shutdown.","triggerScenarios":"Thrown at sdks/java/io/arrow-flight/src/main/java/org/apache/beam/sdk/io/arrowflight/ArrowFlightIO.java:489 when the library encounters an invalid state.","commonSituations":"See trigger scenarios.","solutions":["Inspect the logged exception for the underlying Flight server/connection issue","Usually safe to ignore during shutdown; ensure the Flight server is healthy if streams fail consistently"],"exampleFix":null,"handlingStrategy":"try-catch","validationCode":null,"typeGuard":null,"tryCatchPattern":null,"preventionTips":[],"tags":[],"backgroundTag":null,"analyzedSha":"12126d8942aaf848030c478b4c6a28c6af861c66","analyzedAt":"2026-09-13T01:50:10.254Z","contentChangedAt":"2026-09-13T01:50:10.254Z","schemaVersion":2},"datasetVersion":"2026-09-20T03:17:13.778Z"}