This is an automated email from the ASF dual-hosted git repository.
github-merge-queue[bot] pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git
The following commit(s) were added to refs/heads/dev by this push:
new 54e36f8934 [Fix][Zeta] Close FileOutputStream when storing connector
jar file (#11993)
54e36f8934 is described below
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(
