Permalink
Browse files

Avoid never output'ing if the mapper_batch_size app env changes @ run…

…time
  • Loading branch information...
1 parent e8cb93e commit dbc9b84e716ed3ff47c76989943366093c074309 @slfritchie slfritchie committed with kellymclaughlin Mar 4, 2011
Showing with 1 addition and 1 deletion.
  1. +1 −1 src/riak_kv_map_phase.erl
@@ -222,7 +222,7 @@ maybe_done(#state{done=Done, fsms=FSMs, mapper_data=MapperData, pending=Pending}
end;
false ->
BatchSize = app_helper:get_env(riak_kv, mapper_batch_size, 5),
- case length(Pending) == BatchSize of
+ case length(Pending) >= BatchSize of
true ->
{output, Pending, State#state{pending=[]}};
false ->

0 comments on commit dbc9b84

Please sign in to comment.