Function GetHdfsErrorMsg

be/src/util/hdfs-util.cc:46–59

const char* FILESYS_PREFIX_OBS = "obs://";

string GetHdfsErrorMsg(const string& prefix, const string& file) {
  string error_msg = GetStrErrMsg();
  stringstream ss;
  ss << prefix << file << "\n" << error_msg;
  char* root_cause = hdfsGetLastExceptionRootCause();
  if (root_cause != nullptr) {
    ss << "\nRoot cause: " << root_cause;
  }
  char* stack_trace = hdfsGetLastExceptionStackTrace();
  if (stack_trace != nullptr) {
    ss << "\nStack trace:\n" << stack_trace;
  }
  return ss.str();
}

Status GetFileSize(const hdfsFS& connection, const char* filename, int64_t* filesize) {
  hdfsFileInfo* info = hdfsGetPathInfo(connection, filename);