Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with
or
.
Download ZIP
Browse files

typo: riak_pipe:eoi, not riak_kv_pipe:eoi

  • Loading branch information...
commit 83e28a47c9489c0598f5eb5f7389e4545338e54b 1 parent 7accb0c
@beerriot beerriot authored
Showing with 2 additions and 2 deletions.
  1. +2 −2 src/riak_kv_wm_mapred.erl
View
4 src/riak_kv_wm_mapred.erl
@@ -148,10 +148,10 @@ pipe_mapred(RD,
pipe_mapred_nonchunked(RD, State, Pipe, NumKeeps)
end;
{error, {bad_filter, _}} ->
- riak_kv_pipe:eoi(Pipe),
+ riak_pipe:eoi(Pipe),
{{halt, 500}, send_error({error, bad_mapred_filter}, RD), State};
Error ->
- riak_kv_pipe:eoi(Pipe),
+ riak_pipe:eoi(Pipe),
{{halt, 500}, send_error(Error, RD), State}
end.
Please sign in to comment.
Something went wrong with that request. Please try again.