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必须无条件与其同步。