В кластере четыре узла данных. Я отправляю задачи на три других узла данных удаленно через один из них. Тогда как я могу отменить задачи, отправленные ранее через узел данных?
def remoteJob(){ } rpc(datanode1, submitJob, "job1", "job1", remoteJob)