for(chunkID in chunkIDs){ nodes = exec top 1 node from pnodeRun(getAllChunks) where chunkId=chunkID order by version desc rpc(getControllerAlias(), forceCorrectVersionByReplica{chunkID, nodes[0]}) }
forceCorrectVersionByReplica该函数功能是,强制该chunk 以nodealias上的版本和数据为准,Controller 和其他的datanode必须无条件与其同步。