Skip to content

Commit

Permalink
Fixed metrics issue when trackRun was disabled.
Browse files Browse the repository at this point in the history
  • Loading branch information
pravinbhat committed Nov 8, 2024
1 parent 59938da commit fb2f3fe
Showing 1 changed file with 2 additions and 0 deletions.
2 changes: 2 additions & 0 deletions src/main/java/com/datastax/cdm/job/DiffJobSession.java
Original file line number Diff line number Diff line change
Expand Up @@ -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,
Expand Down

0 comments on commit fb2f3fe

Please sign in to comment.