diff --git a/executor/executor_runner.h b/executor/executor_runner.h index 88fc785dbf07..5f2724b5871f 100644 --- a/executor/executor_runner.h +++ b/executor/executor_runner.h @@ -379,6 +379,9 @@ class Proc debug("proc %d: start executing request %llu\n", id_, static_cast(msg_->id)); + // Executor expects the output_data memory to be already zeroed. + resp_mem_->Reset(); + rpc::ExecutingMessageRawT exec; exec.id = msg_->id; exec.proc_id = id_; @@ -447,7 +450,6 @@ class Proc auto data = finish_output(resp_mem_, id_, msg_->id, num_calls, elapsed, freshness_++, status, hanged, output); conn_.Send(data.data(), data.size()); - resp_mem_->Reset(); msg_.reset(); output_.clear(); debug_output_pos_ = 0;