Skip to content
Browse files

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

…time
  • Loading branch information...
1 parent 3a0d438 commit 8a1ee02014e295253e9a39c28af22ee4249cce4a @slfritchie slfritchie committed with kellymclaughlin Mar 4, 2011
Showing with 1 addition and 1 deletion.
  1. +1 −1 src/riak_kv_map_phase.erl
View
2 src/riak_kv_map_phase.erl
@@ -223,7 +223,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 8a1ee02

Please sign in to comment.
Something went wrong with that request. Please try again.