[GitHub] [hudi] nsivabalan commented on issue #4146: [SUPPORT] Deltastreamer commits with a custom checkpoint configuration are skipped if the generated checkpoint matches the previous commit checkpoint

[GitBox]

nsivabalan commented on issue #4146:
URL: https://github.com/apache/hudi/issues/4146#issuecomment-988891080


   gotcha. guess the way you set the checkpoint should work based on this code 
block
   ```
           if (cfg.checkpoint != null && 
(StringUtils.isNullOrEmpty(commitMetadata.getMetadata(CHECKPOINT_RESET_KEY))
                   || 
!cfg.checkpoint.equals(commitMetadata.getMetadata(CHECKPOINT_RESET_KEY)))) {
             resumeCheckpointStr = Option.of(cfg.checkpoint);
   ```
   
   Can you enable debug logs and post it here. In the mean time, I will try to 
reproduce this locally and will post an update here. 
   


-- 
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-unsubscr...@hudi.apache.org

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