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.