This is an automated email from the ASF dual-hosted git repository.
wanghailin 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 eee881af91 [BugFix][Connector-file-sftp] Fix SFTPInputStream.close
does not correctly trigger the closing of the file stream (#6323) (#6329)
eee881af91 is described below
commit eee881af918ce8ac8faaf09c5a49e197298d7406
Author: Zhihong Pan <[email protected]>
AuthorDate: Sun Feb 18 10:57:55 2024 +0800
[BugFix][Connector-file-sftp] Fix SFTPInputStream.close does not correctly
trigger the closing of the file stream (#6323) (#6329)
---
.../seatunnel/connectors/seatunnel/file/sftp/system/SFTPInputStream.java | 1 +
1 file changed, 1 insertion(+)
diff --git
a/seatunnel-connectors-v2/connector-file/connector-file-sftp/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sftp/system/SFTPInputStream.java
b/seatunnel-connectors-v2/connector-file/connector-file-sftp/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sftp/system/SFTPInputStream.java
index f319e6722a..a9cd9d4fb9 100644
---
a/seatunnel-connectors-v2/connector-file/connector-file-sftp/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sftp/system/SFTPInputStream.java
+++
b/seatunnel-connectors-v2/connector-file/connector-file-sftp/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sftp/system/SFTPInputStream.java
@@ -110,6 +110,7 @@ public class SFTPInputStream extends FSInputStream {
if (closed) {
return;
}
+ wrappedStream.close();
super.close();
closed = true;
if (!channel.isConnected()) {
