code: 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");
          }
      }
docs: clean the directory , sub-directories of STORM-LOCAL-DIR/workers/workerId
  
  @param conf     storm conf
  @param workerId worker id