Method taskStats

bolt/exec/Task.cpp:2319–2374

}

TaskStats Task::taskStats() const {
  std::lock_guard<std::timed_mutex> l(mutex_);

  // 'taskStats_' contains task stats plus stats for the completed drivers
  // (their operators).
  TaskStats taskStats = taskStats_;

  taskStats.numTotalDrivers = drivers_.size();

  // Add stats of the drivers (their operators) that are still running.
  for (const auto& driver : drivers_) {
    // Driver can be null.
    if (driver == nullptr) {
      ++taskStats.numCompletedDrivers;
      continue;
    }

    for (auto& op : driver->operators()) {
      auto statsCopy = op->stats(false);
      aggregateOperatorRuntimeStats(statsCopy.runtimeStats);
      addRunningTimeOperatorMetrics(statsCopy);
      taskStats.pipelineStats[statsCopy.pipelineId]
          .operatorStats[statsCopy.operatorId]
          .add(statsCopy);
    }
    if (driver->isOnThread()) {
      ++taskStats.numRunningDrivers;
    } else if (driver->isTerminated()) {
      ++taskStats.numTerminatedDrivers;
    } else {
      ++taskStats.numBlockedDrivers[driver->blockingReason()];
    }
    // Find the longest running operator.
    auto ocs = driver->opCallStatus();
    if (!ocs.empty()) {
      const auto callDuration = ocs.callDuration();
      if (callDuration > taskStats.longestRunningOpCallMs) {
        taskStats.longestRunningOpCall =
            ocs.formatCall(driver->findOperatorNoThrow(ocs.opId), ocs.method);
        taskStats.longestRunningOpCallMs = callDuration;
      }
    }
  }

  // Don't bother with operator calls running under 30 seconds.
  if (taskStats.longestRunningOpCallMs < 30000) {
    taskStats.longestRunningOpCall.clear();
    taskStats.longestRunningOpCallMs = 0;
  }

  auto bufferManager = bufferManager_.lock();
  taskStats.outputBufferUtilization = bufferManager->getUtilization(taskId_);
  taskStats.outputBufferOverutilized = bufferManager->isOverutilized(taskId_);
  taskStats.outputBufferStats = bufferManager->stats(taskId_);
  return taskStats;
}

bool Task::getLongRunningOpCalls(