* refine dist train RPC deps * clean up * clean up * fix ut * remove input for fetch_barrier * follow comments