public void requestHandoff ( String workUnit ) throws InterruptedException { LOG . info ( "Requesting handoff for {}." , workUnit ) ; ZKUtils . createEphemeral ( zk , "/" + name + "/handoff-requests/" + workUnit ) ; }
Requests that another node take over for a work unit by creating a ZNode at handoff - requests . This will trigger a claim cycle and adoption .