This is an automated email from the ASF dual-hosted git repository. github-merge-queue[bot] pushed a commit to branch gh-readonly-queue/dev/pr-11993-e1ed57b61f4a77e59e68a80a1e91e400c2b5e2f7 in repository https://gitbox.apache.org/repos/asf/seatunnel.git
commit 54e36f89341ef1536b7469c73b493e77291401bb Author: corgy-w <[email protected]> AuthorDate: Sat Aug 29 02:44:45 2026 +0000 [Fix][Zeta] Close FileOutputStream when storing connector jar file (#11993) --- .../engine/server/service/jar/ServerConnectorPackageClient.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/service/jar/ServerConnectorPackageClient.java b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/service/jar/ServerConnectorPackageClient.java index ed782991f6..4511a56dfd 100644 --- a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/service/jar/ServerConnectorPackageClient.java +++ b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/service/jar/ServerConnectorPackageClient.java @@ -88,8 +88,9 @@ public class ServerConnectorPackageClient { boolean success = false; try { if (!storageFile.exists()) { - FileOutputStream fos = new FileOutputStream(storageFile); - fos.write(connectorJarByteData); + try (FileOutputStream fos = new FileOutputStream(storageFile)) { + fos.write(connectorJarByteData); + } } else { LOGGER.warning( String.format(
