Add comment

apache · Oct 8, 2024 · 433b42f · 433b42f
1 parent ba7012a
commit 433b42f
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/...nt/src/main/java/org/apache/gobblin/data/management/copy/publisher/CopyDataPublisher.java b/...nt/src/main/java/org/apache/gobblin/data/management/copy/publisher/CopyDataPublisher.java
@@ -359,6 +359,7 @@ private void publishFileSet(CopyEntity.DatasetAndPartition datasetAndPartition,
       if (copyEntity instanceof CopyableFile) {
         CopyableFile copyableFile = (CopyableFile) copyEntity;
         if (wus.getWorkingState() == WorkingState.COMMITTED) {
+          // Committed files should exist in destination otherwise FNFE will be thrown
           preserveFileAttrInPublisher(copyableFile);
           CopyEventSubmitterHelper.submitSuccessfulFilePublish(this.eventSubmitter, copyableFile, wus);
           // Dataset Output path is injected in each copyableFile.