[Fix-16918][Task] Fix wrong permissions configuration while executing shell

dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/utils/FileUtils.java

@@ -36,12 +36,11 @@
 import java.io.InputStream;
 import java.net.URL;
 import java.nio.charset.StandardCharsets;
-import java.nio.file.FileAlreadyExistsException;
-import java.nio.file.Files;
-import java.nio.file.Path;
-import java.nio.file.Paths;
+import java.nio.file.*;
 import java.nio.file.attribute.PosixFilePermission;
 import java.nio.file.attribute.PosixFilePermissions;
+import java.nio.file.attribute.UserPrincipal;
+import java.nio.file.attribute.UserPrincipalLookupService;
 import java.util.Optional;
 import java.util.Set;
 import java.util.zip.CRC32;
@@ -272,6 +271,12 @@ public static void createDirectoryWith755(@NonNull Path path) throws IOException
         }
     }
 
+    public static Path setOwner(@NonNull Path path, @NonNull String owner) throws IOException {
+        UserPrincipalLookupService lookupService = FileSystems.getDefault().getUserPrincipalLookupService();
+        UserPrincipal user = lookupService.lookupPrincipalByName(owner);
+        return Files.setOwner(path, user);
+    }
+
     public static void setFileTo755(File file) throws IOException {
         if (OSUtils.isWindows()) {
             return;

dolphinscheduler-worker/src/main/java/org/apache/dolphinscheduler/server/worker/utils/TaskExecutionContextUtils.java

@@ -32,6 +32,7 @@
 
 import java.io.File;
 import java.nio.file.Files;
+import java.nio.file.Path;
 import java.nio.file.Paths;
 import java.util.List;
 
@@ -51,6 +52,9 @@ public static void createTaskInstanceWorkingDirectory(TaskExecutionContext taskE
                         taskInstanceWorkingDirectory);
             }
             FileUtils.createDirectoryWith755(Paths.get(taskInstanceWorkingDirectory));
+            final Path taskInstanceWorkingDirectoryPath = Paths.get(taskInstanceWorkingDirectory);
+            FileUtils.createDirectoryWith755(taskInstanceWorkingDirectoryPath);
+            FileUtils.setOwner(taskInstanceWorkingDirectoryPath, taskExecutionContext.getTenantCode());
 
             taskExecutionContext.setExecutePath(taskInstanceWorkingDirectory);
             taskExecutionContext.setAppInfoPath(FileUtils.getAppInfoPath(taskInstanceWorkingDirectory));