public static void tryCleanupWorkerDir(Map conf, String workerId) {
        try {
            // delete heartbeat dir LOCAL_DIR/workers/workid/heartbeats
            PathUtils.rmr(StormConfig.worker_heartbeats_root(conf, workerId));
            // delete pid dir, LOCAL_DIR/workers/workerid/pids
            PathUtils.rmr(StormConfig.worker_pids_root(conf, workerId));
            // delete workerid dir, LOCAL_DIR/worker/workerid
            PathUtils.rmr(StormConfig.worker_root(conf, workerId));
        } catch (Exception e) {
            LOG.warn(e + "Failed to cleanup worker " + workerId + ". Will retry later");
        }
    }
public static void tryCleanupWorkerDir ( Map conf , String workerId ) { try { PathUtils . rmr ( StormConfig . worker_heartbeats_root ( conf , workerId ) ) ; PathUtils . rmr ( StormConfig . worker_pids_root ( conf , workerId ) ) ; PathUtils . rmr ( StormConfig . worker_root ( conf , workerId ) ) ; } catch ( Exception e ) { LOG . warn ( e + "Failed to cleanup worker " + workerId + ". Will retry later" ) ; } }
clean the directory , sub-directories of STORM-LOCAL-DIR/workers/workerId

@param conf     storm conf
@param workerId worker id