From 71c919cdd7d897f63f2fd46db0ee65e61b49a5e3 Mon Sep 17 00:00:00 2001
From: weideng1 <weideng1@users.noreply.github.com>
Date: Mon, 15 Aug 2022 23:23:16 -0600
Subject: [PATCH] only generate checkpoint file when the job does not complete

---
 .../datastax/oss/dsbulk/workflow/commons/log/LogManager.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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(