Method removeSpillDirectoryIfExists

bolt/exec/Task.cpp:520–531

}

void Task::removeSpillDirectoryIfExists() {
  if (spillDirectory_.empty() || !spillDirectoryCreated_) {
    return;
  }
  try {
    auto fs = filesystems::getFileSystem(spillDirectory_, nullptr);
    fs->rmdir(spillDirectory_);
  } catch (const std::exception& e) {
    LOG(ERROR) << "Failed to remove spill directory '" << spillDirectory_
               << "' for Task " << taskId() << ": " << e.what();
  }
}

void Task::initTaskPool() {
  BOLT_CHECK_NULL(pool_);