anchor.diff:                               NewState2 = NewState#rep_state{timer = xdc_vbucket_rep_ckpt:start_timer(State),
                                                               status = VbStatus2},
                                {ok, NewState2};
  -                         Error ->
  +                         {checkpoint_commit_failure, ErrorMsg, NewState} ->
                                %% update the failed ckpt stats to bucket replicator
  -                             {stop, Error, update_status_to_parent(State)}
  +                             Vb = (NewState#rep_state.status)#rep_vb_status.vb,
  +                             ?xdcr_error("checkpoint commit failure during replication for vb ~p, "
  +                                         "error: ~p", [Vb, ErrorMsg]),
  +                             {stop, ErrorMsg, update_status_to_parent(NewState)}
                        end;
                    _ ->
                        %% if get checkpoint when not in replicating state, continue to wait until we
  
positive.code:                      target_name = TargetName,
                       current_through_seq = StartSeq,
                       last_checkpoint_time = LastCkptTime,
                       rep_details = #rep{id = Id, options = Options},
                       status = VbStatus
                      } = State) ->
  
      WorkStart = now(),
  
negative.code:         ok ->
              ok;
          checkpoint_commit_failure ->
              Vb = (ResultState#rep_state.status)#rep_vb_status.vb,
              ?xdcr_debug("checkpoint commit failure at start of replication for vb ~p, "
                          "error: ~p", [Vb, ErrorMsg]),
              exit(ErrorMsg)
      end,
  
  