(seatunnel) branch dev updated: [Improve][File] Clean memory buffer of `JsonWriteStrategy` & `ExcelWriteStrategy` (#5925)

[fanjia]

This is an automated email from the ASF dual-hosted git repository.

fanjia 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 7297a4c95c [Improve][File] Clean memory buffer of `JsonWriteStrategy` 
& `ExcelWriteStrategy` (#5925)
7297a4c95c is described below

commit 7297a4c95c1ad92940d49207b3073b8f24e33c5f
Author: hailin0 <wanghai...@apache.org>
AuthorDate: Tue Nov 28 17:10:06 2023 +0800

    [Improve][File] Clean memory buffer of `JsonWriteStrategy` & 
`ExcelWriteStrategy` (#5925)
---
 .../connectors/seatunnel/file/sink/writer/ExcelWriteStrategy.java       | 1 +
 .../connectors/seatunnel/file/sink/writer/JsonWriteStrategy.java        | 2 ++
 2 files changed, 3 insertions(+)

diff --git 
a/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/writer/ExcelWriteStrategy.java
 
b/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/writer/ExcelWriteStrategy.java
index a158ddf739..6615042222 100644
--- 
a/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/writer/ExcelWriteStrategy.java
+++ 
b/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/writer/ExcelWriteStrategy.java
@@ -62,6 +62,7 @@ public class ExcelWriteStrategy extends AbstractWriteStrategy 
{
                     }
                     needMoveFiles.put(k, getTargetLocation(k));
                 });
+        beingWrittenWriter.clear();
     }
 
     private ExcelGenerator getOrCreateExcelGenerator(@NonNull String filePath) 
{
diff --git 
a/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/writer/JsonWriteStrategy.java
 
b/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/writer/JsonWriteStrategy.java
index 6a4f4b8acf..c3a3a975ca 100644
--- 
a/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/writer/JsonWriteStrategy.java
+++ 
b/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/writer/JsonWriteStrategy.java
@@ -103,6 +103,8 @@ public class JsonWriteStrategy extends 
AbstractWriteStrategy {
                     }
                     needMoveFiles.put(key, getTargetLocation(key));
                 });
+        beingWrittenOutputStream.clear();
+        isFirstWrite.clear();
     }
 
     private FSDataOutputStream getOrCreateOutputStream(@NonNull String 
filePath) {