[incubator-seatunnel] branch dev updated: [Bug][Connector-V2] Fix the bug that file connector release resources multi times (#2379)

[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/incubator-seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new 58c64aab2 [Bug][Connector-V2] Fix the bug that file connector release 
resources multi times (#2379)
58c64aab2 is described below

commit 58c64aab2a167c766d3d13352cfe236243d36fc8
Author: TyrantLucifer <tyrantluci...@gmail.com>
AuthorDate: Mon Aug 8 15:36:57 2022 +0800

    [Bug][Connector-V2] Fix the bug that file connector release resources multi 
times (#2379)
---
 .../seatunnel/file/sink/writer/AbstractTransactionStateFileWriter.java   | 1 -
 1 file changed, 1 deletion(-)

diff --git 
a/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/writer/AbstractTransactionStateFileWriter.java
 
b/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/writer/AbstractTransactionStateFileWriter.java
index b14827b56..85af5a61b 100644
--- 
a/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/writer/AbstractTransactionStateFileWriter.java
+++ 
b/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/writer/AbstractTransactionStateFileWriter.java
@@ -116,7 +116,6 @@ public abstract class AbstractTransactionStateFileWriter 
implements TransactionS
 
     @Override
     public String beginTransaction(@NonNull Long checkpointId) {
-        this.finishAndCloseWriteFile();
         this.transactionId = "T" + Constant.TRANSACTION_ID_SPLIT + jobId + 
Constant.TRANSACTION_ID_SPLIT + subTaskIndex + Constant.TRANSACTION_ID_SPLIT + 
checkpointId;
         this.transactionDir = getTransactionDir(this.transactionId);
         this.needMoveFiles = new HashMap<>();