Method RemoveRemoteDirForHost

be/src/runtime/tmp-file-mgr.cc:473–482

}

void TmpFileMgr::RemoveRemoteDirForHost(const string& dir, hdfsFS hdfs_conn) {
  if (!FLAGS_remote_scratch_cleanup_on_start_stop) return;
  DCHECK(hdfs_conn != nullptr);
  const string hostlevel_dir = ConstructRemoteDirPath(
      dir, ExecEnv::GetInstance()->configured_backend_address().hostname);
  if (hdfsExists(hdfs_conn, hostlevel_dir.c_str()) == 0) {
    hdfsDelete(hdfs_conn, hostlevel_dir.c_str(), 1);
    LOG(INFO) << "Called to remove the host-level remote directory " << hostlevel_dir;
  }
}

void TmpFileMgr::RemoveRemoteDirForQuery(TmpFileGroup* file_group) {
  if (tmp_dirs_remote_ == nullptr) return;