anchor.diff:                      end;
                   false ->
                       MapperData1 = lists:keydelete(Pid, 1, MapperData),
  -                    {no_output, maybe_done(State#state{mapper_data=MapperData1})}
  +                    maybe_done(State#state{mapper_data=MapperData1})
               end;
           false ->
               {stop, {error, {dead_mapper, erlang:get_stacktrace(), MapperData}}, State}
  
positive.code:                                 ClaimLists = riak_kv_mapred_planner:plan_map(NewKeys),
                                  {NewFSMs, _ClaimLists1, FsmKeys} = schedule_input(NewKeys, ClaimLists, QTerm, FSMs, State),
                                  MapperData1 = lists:keydelete(Id, 1, lists:keydelete(Pid, 1, MapperData ++ FsmKeys)),
                                  {no_output, maybe_done(State#state{mapper_data=MapperData1, fsms=NewFSMs})}
                              catch
                                  _:Error ->
                                      {stop, {error, {no_candidate_nodes, Error, erlang:get_stacktrace(), MapperData}}, State}
  
negative.code:             dict:update_counter(Executor, -1, FSMs)
      end.
  
  maybe_done(#state{done=Done, fsms=FSMs, mapper_data=MapperData, pending=Pending}=State) ->
      case Done =:= true andalso dict:size(FSMs) == 0 andalso MapperData == [] of
          true ->
              luke_phase:complete(),
              case Pending of
                  [] ->
                      {no_output, State};
                  _ ->
                      {output, Pending, State#state{pending=[]}}
              end;
          false ->
              BatchSize = app_helper:get_env(riak_kv, mapper_batch_size, 5),
              case length(Pending) == BatchSize of
                  true ->
                      {output, Pending, State#state{pending=[]}};
                  false ->
                      {no_output, State}
              end
      end.
  
  update_inputs(Id, VNode, BKey, MapperData) ->
      case lists:keyfind(Id, 1, MapperData) of
  