You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@seatunnel.apache.org by le...@apache.org on 2022/01/20 01:05:45 UTC
[incubator-seatunnel] branch dev updated: [SeaTunnel #1103] Fix the resource leak in File Flink Sink (#1104)
This is an automated email from the ASF dual-hosted git repository.
leo65535 pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git
The following commit(s) were added to refs/heads/dev by this push:
new 11709d0 [SeaTunnel #1103] Fix the resource leak in File Flink Sink (#1104)
11709d0 is described below
commit 11709d0967983f4fe08234ce51d1cda595110007
Author: Benedict Jin <as...@apache.org>
AuthorDate: Thu Jan 20 09:05:31 2022 +0800
[SeaTunnel #1103] Fix the resource leak in File Flink Sink (#1104)
---
.../src/main/java/org/apache/seatunnel/flink/sink/FileSink.java | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
diff --git a/seatunnel-connectors/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/sink/FileSink.java b/seatunnel-connectors/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/sink/FileSink.java
index 4fd27f6..6e4c6a6 100644
--- a/seatunnel-connectors/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/sink/FileSink.java
+++ b/seatunnel-connectors/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/sink/FileSink.java
@@ -60,8 +60,9 @@ public class FileSink implements FlinkStreamSink<Row, Row>, FlinkBatchSink<Row,
final StreamingFileSink<Row> sink = StreamingFileSink
.forRowFormat(filePath, (Encoder<Row>) (element, stream) -> {
- PrintStream out = new PrintStream(stream);
- out.println(element);
+ try (PrintStream out = new PrintStream(stream)) {
+ out.println(element);
+ }
})
.build();
return dataStream.addSink(sink);