diff --git a/src/main/java/com/datastax/cdm/job/DiffJobSession.java b/src/main/java/com/datastax/cdm/job/DiffJobSession.java index c9e597a3..3d421f0b 100644 --- a/src/main/java/com/datastax/cdm/job/DiffJobSession.java +++ b/src/main/java/com/datastax/cdm/job/DiffJobSession.java @@ -179,6 +179,8 @@ protected void processPartitionRange(PartitionRange range) { } else if (null != trackRunFeature) { jobCounter.globalIncrement(); trackRunFeature.updateCdmRun(runId, min, TrackRun.RUN_STATUS.PASS, jobCounter.getThreadCounters(true)); + } else { + jobCounter.globalIncrement(); } } catch (Exception e) { jobCounter.threadIncrement(JobCounter.CounterType.ERROR,