This is an automated email from the ASF dual-hosted git repository.

wlo pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/gobblin.git


The following commit(s) were added to refs/heads/master by this push:
     new 35145edea [GOBBLIN-2021] Add logging to see when directories have 
their permissions resynced to which perms for manifest distcp (#3897)
35145edea is described below

commit 35145edeab1e5bc09bf646d319da9767e5c849fa
Author: William Lo <[email protected]>
AuthorDate: Thu Mar 21 22:08:21 2024 -0400

    [GOBBLIN-2021] Add logging to see when directories have their permissions 
resynced to which perms for manifest distcp (#3897)
---
 .../gobblin/data/management/copy/publisher/CopyDataPublisher.java      | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/publisher/CopyDataPublisher.java
 
b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/publisher/CopyDataPublisher.java
index 56eb78e4f..855147eb9 100644
--- 
a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/publisher/CopyDataPublisher.java
+++ 
b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/publisher/CopyDataPublisher.java
@@ -196,7 +196,8 @@ public class CopyDataPublisher extends DataPublisher 
implements UnpublishedHandl
     if (copyableFile.getFileStatus().isDirectory() && 
this.resyncDirOwnerAndPermission){
       FileStatus dstFile = 
this.fs.getFileStatus(copyableFile.getDestination());
       // User specifically try to copy dir metadata, so we change the group 
and permissions on destination even when the dir already existed
-      FileAwareInputStreamDataWriter.safeSetPathPermission(this.fs, 
dstFile,copyableFile.getDestinationOwnerAndPermission());
+      log.info("Setting destination directory {} owner and permission to {}", 
dstFile.getPath(), 
copyableFile.getDestinationOwnerAndPermission().getFsPermission());
+      FileAwareInputStreamDataWriter.safeSetPathPermission(this.fs, dstFile, 
copyableFile.getDestinationOwnerAndPermission());
     }
     if (preserveDirModTime || copyableFile.getFileStatus().isFile()) {
       // Preserving File ModTime, and set the access time to an initializing 
value when ModTime is declared to be preserved.

Reply via email to