-
Notifications
You must be signed in to change notification settings - Fork 233
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Using riak_pipe for Map Reduce task may return inconsistent results when one of cluster node is down. #475
Conversation
Reduce phase must be started on live node.
If we can't send reduce result to output we must generate an error, otherwise we will return inconsistent results.
This test is based off one submitted by Alexander Gunin to the riak-users mailing list as an issue reproducer. [http://lists.basho.com/pipermail/riak-users_lists.basho.com/2013-January/010896.html]
Builds on commit in #475 with more documentation, variable name cleanup, and a more failure-tolerant up-vnode-finder strategy.
Squashed commit of the following: commit 0c07454 Author: Bryan Fink <bryan@basho.com> Date: Sat Feb 2 10:17:43 2013 -0500 cleanup and rework contant reduce hash Builds on commit in #475 with more documentation, variable name cleanup, and a more failure-tolerant up-vnode-finder strategy. commit 58040e8 Author: Dreyk <gunin@satissoft.ru> Date: Fri Feb 1 13:44:49 2013 +0400 Update src/riak_kv_mrc_pipe.erl Reduce phase must be started on live node.
As the github history indicates, I cleaned up the first patch in this PR (for the constant reduce hash) for incorporation into Riak's 1.3 RC2. We'll review the second patch (for handling reduce phase errors) separately. Thank you! |
@beerriot Did the second patch ever get merged? |
@evanmcc Nope, it sure didn't. Want to submit a PR? |
Pulling PRs out of the freezer ... Hrm, looks like an impasse. Does the 2nd patch exist someplace? |
I don't think so. It'd be a process of looking at this PR, and Bryan's |
Using riak_pipe for Map Reduce task may return inconsistent results(for example empty list,however all data are available).
See http://lists.basho.com/pipermail/riak-users_lists.basho.com/2013-January/010870.html