Repairing Secondary Indexes
The riak-admin repair-2i
command can be used to repair any stale or missing secondary indexes. This command scans and repairs any mismatches between the secondary index data used for querying and the secondary index data stored in the Riak objects. It can be run on all partitions of a node or on a subset of them. We recommend scheduling these repairs outside of peak load time.
Running a Repair
The secondary indexes of a single partition can be repaired by executing:
riak-admin repair-2i <Partition_ID>
The secondary indexes of every partition can be repaired by executing the same command, without a partition ID:
riak-admin repair-2i
Monitoring a Repair
Repairs can be monitored using the below command:
riak-admin repair-2i status
Killing a Repair
In the event the secondary index repair operation needs to be halted, all repairs can be killed with:
riak-admin repair-2i kill
Running a Repair
If a replica loss has occurred, you need to run the repair command. This command repairs objects from a node’s adjacent partitions on the ring.
This is done as efficiently as possible by generating a hash range for all the buckets and thus avoiding a preflist calculation for each key. Only a hash of each key is done, its range determined from a bucket→range map, and then the hash is checked against the range.
This code will force all keys in each partition on a node to be reread.
From a cluster node with Riak installed, attach to the Riak console:
riak attach
You may have to hit enter again to get a console prompt.
Get a list of partitions owned by the node that needs repair:
{ok, Ring} = riak_core_ring_manager:get_my_ring().
You will get a lot of output with Ring record information. You can safely ignore it.
Then run the following code to get a list of partitions. Replace ‘dev1@127.0.0.1’ with the name of the node you need to repair.
Partitions = [P || {P, 'dev1@127.0.0.1'} <- riak_core_ring:all_owners(Ring)].
_Note: The above is an Erlang list comprehension, that loops over each
{Partition, Node}
tuple in the Ring, and extracts only the partitions that match the given node name, as a list._Execute repair on all the partitions. Executing them all at once like this will cause a lot of
{shutdown,max_concurrency}
spam but it’s not anything to worry about. That is just the transfers mechanism enforcing an upper limit on the number of concurrent transactions.[riak_search_vnode:repair(P) || P <- Partitions].
When you’re done, press
Ctrl-D
to disconnect the console. DO NOT RUN q() which will cause the running Riak node to quit. Note thatCtrl-D
merely disconnects the console from the service, it does not stop the code from running.
Monitoring a Repair
The above Repair command can be slow, so if you reattach to the console, you can run the repair_status function. You can use the Partitions
variable defined above to get the status of every partition.
[{P, riak_search_vnode:repair_status(P)} || P <- Partitions].
When you’re done, press Ctrl-D
to disconnect the console.
Killing a Repair
Currently there is no easy way to kill an individual repair. The only
option is to kill all repairs targeting a given node. This is done by
running riak_core_vnode_manager:kill_repairs(Reason)
on the node
undergoing repair. This means you’ll either have to be attached to
that node’s console or you can use the rpc
module to make a remote
call. Here is an example of killing all repairs targeting partitions
on the local node.
riak_core_vnode_manager:kill_repairs(killed_by_user).
Log entries will reflect that repairs were killed manually, something akin to this:
2012-08-10 10:14:50.529 [warning] <0.154.0>@riak_core_vnode_manager:handle_cast:395 Killing all repairs: killed_by_user
Here is an example of executing the call remotely.
rpc:call('dev1@127.0.0.1', riak_core_vnode_manager, kill_repairs, [killed_by_user]).
When you’re done, press Ctrl-D
to disconnect the console.
Repairs are not allowed to occur during ownership changes. Since ownership entails the moving of partition data it is safest to make them mutually exclusive events. If you join or remove a node all repairs across the entire cluster will be killed.