After looking at the code, I strongly feel we need to refactor the communication between datanode and coordinator OR coordinator to coordinator. The code in these modules is duplicated, lacks in proper error handling, and the code is not modularised. I think we should take this up after 1.0 release ASAP.
3Q