From 0dc121ddbd0449e8cb5726bef04a494602965ff9 Mon Sep 17 00:00:00 2001 From: arjit3251 Date: Wed, 17 Dec 2025 11:14:16 +0530 Subject: [PATCH] Populate file set property in CopyableFile for IcebergFileStreamExtractor --- .../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 10cabfc9c47..63b65cf2078 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 Iterator downloadFile(String filePath) throws IOExc 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();