[BugFix][Connector-file-sftp] Fix SFTPInputStream.close does not corr…

…ectly trigger the closing of the file stream (apache#6323) (apache#6329)
chaorongzhi · Aug 21, 2024 · 3176231 · 3176231
1 parent 223e343
commit 3176231
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/...main/java/org/apache/seatunnel/connectors/seatunnel/file/sftp/system/SFTPInputStream.java b/...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()) {