From bf8884f2bf176c3035cbfa4fd9792087151e47df Mon Sep 17 00:00:00 2001
From: ZhongLinLeo <45789867+ZhongLinLeo@users.noreply.github.com>
Date: Thu, 16 Oct 2025 19:46:56 +0800
Subject: [PATCH] Add workDir field to SFTPFileSystem class

---
 .../seatunnel/file/sftp/system/SFTPFileSystem.java         | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git a/seatunnel-connectors-v2/connector-file/connector-file-sftp/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sftp/system/SFTPFileSystem.java b/seatunnel-connectors-v2/connector-file/connector-file-sftp/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sftp/system/SFTPFileSystem.java
index 99bf4177639..13dce746ec2 100644
--- a/seatunnel-connectors-v2/connector-file/connector-file-sftp/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sftp/system/SFTPFileSystem.java
+++ b/seatunnel-connectors-v2/connector-file/connector-file-sftp/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sftp/system/SFTPFileSystem.java
@@ -83,6 +83,8 @@ public class SFTPFileSystem extends FileSystem {
     public static final String E_FAILED_GETHOME = "Failed to get home directory";
     public static final String E_FAILED_DISCONNECT = "Failed to disconnect";
 
+    public Path workDir;
+
     private void setConfigurationFromURI(URI uriInfo, Configuration conf) throws IOException {
 
         // get host information from URI
@@ -607,7 +609,10 @@ public void setWorkingDirectory(Path newDir) {
     @Override
     public Path getWorkingDirectory() {
         // Return home directory always since we do not maintain state.
-        return getHomeDirectory();
+        if (workDir == null) {
+            workDir = getHomeDirectory();
+        }
+        return workDir;
     }
 
     @Override