From 317623146704d9d0d4a0180be71f82a2b01b9e11 Mon Sep 17 00:00:00 2001
From: Zhihong Pan <49435072+panpan2019@users.noreply.github.com>
Date: Sun, 18 Feb 2024 10:57:55 +0800
Subject: [PATCH] [BugFix][Connector-file-sftp] Fix SFTPInputStream.close does
 not correctly trigger the closing of the file stream (#6323) (#6329)

---
 .../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 f319e6722a8f..a9cd9d4fb9d3 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 synchronized void close() throws IOException {
         if (closed) {
             return;
         }
+        wrappedStream.close();
         super.close();
         closed = true;
         if (!channel.isConnected()) {