diff --git a/workflow/commons/src/main/java/com/datastax/oss/dsbulk/workflow/commons/log/LogManager.java b/workflow/commons/src/main/java/com/datastax/oss/dsbulk/workflow/commons/log/LogManager.java index 312a08d58..616e8d516 100644 --- a/workflow/commons/src/main/java/com/datastax/oss/dsbulk/workflow/commons/log/LogManager.java +++ b/workflow/commons/src/main/java/com/datastax/oss/dsbulk/workflow/commons/log/LogManager.java @@ -254,7 +254,7 @@ public void reportAvailableFiles() throws IOException { } if (checkpointEnabled) { CheckpointManager manager = mergeCheckpointManagers(); - if (!manager.isEmpty()) { + if (!manager.isEmpty() && !manager.isComplete(replayStrategy)) { writeCheckpointFile(manager); LOGGER.info("Checkpoints for the current operation were written to {}.", CHECKPOINT_CSV); LOGGER.info(