(gobblin) branch master updated: Populate file set property in CopyableFile for IcebergFileStreamExtractor (#4161)

[abhijain]

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

abhijain 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 6619cb1253 Populate file set property in CopyableFile for 
IcebergFileStreamExtractor (#4161)
6619cb1253 is described below

commit 6619cb1253572523a9953d73859552a4086556e4
Author: thisisArjit <thisisar...@gmail.com>
AuthorDate: Wed Dec 17 12:00:49 2025 +0530

    Populate file set property in CopyableFile for IcebergFileStreamExtractor 
(#4161)
---
 .../gobblin/data/management/copy/iceberg/IcebergFileStreamExtractor.java | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/iceberg/IcebergFileStreamExtractor.java
 
b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/iceberg/IcebergFileStreamExtractor.java
index 10cabfc9c4..63b65cf207 100644
--- 
a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/iceberg/IcebergFileStreamExtractor.java
+++ 
b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/iceberg/IcebergFileStreamExtractor.java
@@ -150,6 +150,7 @@ public class IcebergFileStreamExtractor extends 
FileBasedExtractor<String, FileA
             sourcePath.getParent(), PathUtils.getRootPathChild(sourcePath), 
copyConfiguration);
     // Build CopyableFile using cached targetFs and copyConfiguration 
(initialized once in constructor)
     CopyableFile copyableFile = 
CopyableFile.fromOriginAndDestination(originFs, originStatus, destinationPath, 
this.copyConfiguration)
+        .fileSet(workUnit.getProp(ConfigurationKeys.DATASET_URN_KEY))
         .datasetOutputPath(targetFs.getUri().getPath())
         .ancestorsOwnerAndPermission(ancestorOwnerAndPermissionList)
         .build();