From ed7aa138e80d6fefab58951dde42c404ccca2ece Mon Sep 17 00:00:00 2001 From: Harsha Teja Kanna Date: Fri, 28 Jan 2022 22:08:25 -0600 Subject: [PATCH] [MINOR] Added log to debug checkpoint resumption when set to 0 (#4650) --- .../java/org/apache/hudi/utilities/deltastreamer/DeltaSync.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer/DeltaSync.java b/hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer/DeltaSync.java index 5c2b69293..108cd78a7 100644 --- a/hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer/DeltaSync.java +++ b/hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer/DeltaSync.java @@ -370,6 +370,7 @@ public class DeltaSync implements Serializable { .initTable(new Configuration(jssc.hadoopConfiguration()), cfg.targetBasePath); } + LOG.debug("Checkpoint from config: " + cfg.checkpoint); if (!resumeCheckpointStr.isPresent() && cfg.checkpoint != null) { resumeCheckpointStr = Option.of(cfg.checkpoint); } @@ -470,6 +471,7 @@ public class DeltaSync implements Serializable { Option commitMetadataOption = getLatestCommitMetadataWithValidCheckpointInfo(commitTimelineOpt.get()); if (commitMetadataOption.isPresent()) { HoodieCommitMetadata commitMetadata = commitMetadataOption.get(); + LOG.debug("Checkpoint reset from metadata: " + commitMetadata.getMetadata(CHECKPOINT_RESET_KEY)); if (cfg.checkpoint != null && (StringUtils.isNullOrEmpty(commitMetadata.getMetadata(CHECKPOINT_RESET_KEY)) || !cfg.checkpoint.equals(commitMetadata.getMetadata(CHECKPOINT_RESET_KEY)))) { resumeCheckpointStr = Option.of(cfg.checkpoint);