This is an automated email from the ASF dual-hosted git repository.
vivekrai 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 4a041b8b96 added missing source and destinatin data required for
lineage (#4170)
4a041b8b96 is described below
commit 4a041b8b96d891da7f779e4e201089278eddbe2a
Author: Vivek Rai <[email protected]>
AuthorDate: Fri Mar 6 19:44:47 2026 +0530
added missing source and destinatin data required for lineage (#4170)
---
.../data/management/copy/iceberg/IcebergPartitionCopyableFile.java | 3 +++
1 file changed, 3 insertions(+)
diff --git
a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/iceberg/IcebergPartitionCopyableFile.java
b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/iceberg/IcebergPartitionCopyableFile.java
index 5a0bc6d8f3..54a1c7ffc4 100644
---
a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/iceberg/IcebergPartitionCopyableFile.java
+++
b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/iceberg/IcebergPartitionCopyableFile.java
@@ -50,6 +50,9 @@ public class IcebergPartitionCopyableFile extends
CopyableFile {
copyableFile.getAncestorsOwnerAndPermission(),
copyableFile.getChecksum(), copyableFile.getPreserve(),
copyableFile.getFileSet(), copyableFile.getOriginTimestamp(),
copyableFile.getUpstreamTimestamp(),
copyableFile.getAdditionalMetadata(), copyableFile.datasetOutputPath,
copyableFile.getDataFileVersionStrategy());
+ // Ensure that the source and destination data are set in the new copyable
file for lineage
+ this.setSourceData(copyableFile.getSourceData());
+ this.setDestinationData(copyableFile.getDestinationData());
this.base64EncodedDataFile = SerializationUtil.serializeToBase64(dataFile);
}
