Inside of ZkClientDn::initWorkQueue we should immediately run the "replicate" and "delete" commands on the DataNode if the queues are not empty on DataNodeRegistration. Thus the ZkClientDn will probably need some way to reference the DataTransfer + RPC Server for that DataNode. Feel free to msg me on Slack if you have any questions.
For now maybe just throw a TODO in that section of the code or coordinate with the DataNode server teams to hook this up.
Inside of ZkClientDn::initWorkQueue we should immediately run the "replicate" and "delete" commands on the DataNode if the queues are not empty on DataNodeRegistration. Thus the ZkClientDn will probably need some way to reference the DataTransfer + RPC Server for that DataNode. Feel free to msg me on Slack if you have any questions.
For now maybe just throw a TODO in that section of the code or coordinate with the DataNode server teams to hook this up.