(gobblin) branch master updated: Remove unnecessary CopyEntity deserialisation (#4132)

[vivekrai]

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 1ab8993124 Remove unnecessary CopyEntity deserialisation (#4132)
1ab8993124 is described below

commit 1ab8993124cf46e37e430af384fff652c350b0e6
Author: thisisArjit <thisisar...@gmail.com>
AuthorDate: Wed Aug 27 08:11:08 2025 +0530

    Remove unnecessary CopyEntity deserialisation (#4132)
---
 .../java/org/apache/gobblin/data/management/copy/CopySource.java    | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/CopySource.java
 
b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/CopySource.java
index 180eefac9e..5f9a75db1e 100644
--- 
a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/CopySource.java
+++ 
b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/CopySource.java
@@ -400,7 +400,7 @@ public class CopySource extends AbstractSource<String, 
FileAwareInputStream> {
           workUnit.setProp(SlaEventKeys.PARTITION_KEY, 
copyEntity.getFileSet());
           setWorkUnitWeight(workUnit, copyEntity, minWorkUnitWeight);
           setWorkUnitWatermark(workUnit, watermarkGenerator, copyEntity);
-          computeAndSetWorkUnitGuid(workUnit);
+          computeAndSetWorkUnitGuid(workUnit, copyEntity);
           addLineageInfo(copyEntity, workUnit);
           if (copyEntity instanceof CopyableFile) {
             CopyableFile castedCopyEntity = (CopyableFile) copyEntity;
@@ -514,11 +514,11 @@ public class CopySource extends AbstractSource<String, 
FileAwareInputStream> {
     workUnit.setProp(WORK_UNIT_WEIGHT, Long.toString(weight));
   }
 
-  private static void computeAndSetWorkUnitGuid(WorkUnit workUnit)
+  private static void computeAndSetWorkUnitGuid(WorkUnit workUnit, CopyEntity 
copyEntity)
       throws IOException {
     Guid guid = 
Guid.fromStrings(workUnit.contains(ConfigurationKeys.CONVERTER_CLASSES_KEY) ? 
workUnit
         .getProp(ConfigurationKeys.CONVERTER_CLASSES_KEY) : "");
-    setWorkUnitGuid(workUnit, guid.append(deserializeCopyEntity(workUnit)));
+    setWorkUnitGuid(workUnit, guid.append(copyEntity.guid()));
   }
 
   /**