You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hudi.apache.org by "Leoyzen (via GitHub)" <gi...@apache.org> on 2023/02/02 14:45:59 UTC

[GitHub] [hudi] Leoyzen commented on issue #7823: [SUPPORT]No execution calls after rollback compaction while using offline flink compactor.

Leoyzen commented on issue #7823:
URL: https://github.com/apache/hudi/issues/7823#issuecomment-1413857325

   ```JAVA
         List<HoodieInstant> instants = compactionInstantTimes.stream().map(HoodieTimeline::getCompactionRequestedInstant).collect(Collectors.toList());
         for (HoodieInstant instant : instants) {
           if (!pendingCompactionTimeline.containsInstant(instant)) {
             // this means that the compaction plan was written to auxiliary path(.tmp)
             // but not the meta path(.hoodie), this usually happens when the job crush
             // exceptionally.
             // clean the compaction plan in auxiliary path and cancels the compaction.
             LOG.warn("The compaction plan was fetched through the auxiliary path(.tmp) but not the meta path(.hoodie).\n"
                 + "Clean the compaction plan in auxiliary path and cancels the compaction");
             CompactionUtil.cleanInstant(table.getMetaClient(), instant);
             return;
           }
         }
   ```
   
   Why would it "return" instead of cleaning all the instants?


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org