Method Exec

be/src/runtime/fragment-instance-state.cc:94–153

    instance_ctx_pb_(instance_ctx_pb) {}

Status FragmentInstanceState::Exec() {
  bool is_prepared = false;
  Status status = Prepare();
  DCHECK(runtime_state_ != nullptr);  // we need to guarantee at least that

  if (!status.ok()) {
    discard_result(opened_promise_.Set(status));
    goto done;
  }
  // Tell the managing 'QueryState' that we're done with Prepare().
  query_state_->DonePreparing();
  is_prepared = true;

  status = Open();
  discard_result(opened_promise_.Set(status));
  if (!status.ok()) goto done;

  {
    // Must go out of scope before Finalize(), otherwise counter will not be
    // updated by time final profile is sent.
    SCOPED_TIMER2(profile()->total_time_counter(),
        ADD_TIMER(timings_profile_, EXEC_TIMER_NAME));
    status = ExecInternal();
  }

done:
  // Don't transition to completion until Close() is called as some new errors may be
  // logged in RuntimeState:error_log_.
  Close();

  DCHECK_EQ(is_prepared,
      current_state_.Load() > FInstanceExecStatePB::WAITING_FOR_PREPARE);

  if (!status.ok()) {
    exec_failed_.Store(true);
    if (!is_prepared) {
      UpdateState(StateEvent::EXEC_END);

      // Tell the managing 'QueryState' that we hit an error during Prepare().
      query_state_->ErrorDuringPrepare(status, instance_id());
    } else {
      // Must set exec_failed_ first, then update the 'Query State' before updating the
      // fragment instance state. Otherwise, there is a race when reading the 'done' flag
      // with GetStatusReport(). This may lead to report the instance as "completed"
      // without error, or the "final" profile being sent with the 'done' flag as false.

      // Tell the managing 'QueryState' that we hit an error during execution.
      query_state_->ErrorDuringExecute(status, instance_id());

      UpdateState(StateEvent::EXEC_END);
      query_state_->DoneRemainingExecuting();
    }
  } else {
    UpdateState(StateEvent::EXEC_END);

    // Tell the managing 'QueryState' that we're done with executing.
    query_state_->DoneExecuting();
  }