You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@arrow.apache.org by ag...@apache.org on 2024/03/05 14:48:33 UTC
(arrow-ballista) branch main updated: Fix ExecutorLost event debug info (#988)
This is an automated email from the ASF dual-hosted git repository.
agrove pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/arrow-ballista.git
The following commit(s) were added to refs/heads/main by this push:
new 1be0a467 Fix ExecutorLost event debug info (#988)
1be0a467 is described below
commit 1be0a467a7b50e9873b02016b8ed343174f3f9cf
Author: 张林伟 <le...@gmail.com>
AuthorDate: Tue Mar 5 22:48:27 2024 +0800
Fix ExecutorLost event debug info (#988)
---
ballista/scheduler/src/scheduler_server/event.rs | 7 +++++--
1 file changed, 5 insertions(+), 2 deletions(-)
diff --git a/ballista/scheduler/src/scheduler_server/event.rs b/ballista/scheduler/src/scheduler_server/event.rs
index 99b938a1..54fdf26a 100644
--- a/ballista/scheduler/src/scheduler_server/event.rs
+++ b/ballista/scheduler/src/scheduler_server/event.rs
@@ -124,8 +124,11 @@ impl Debug for QueryStageSchedulerEvent {
QueryStageSchedulerEvent::ReviveOffers => {
write!(f, "ReviveOffers.")
}
- QueryStageSchedulerEvent::ExecutorLost(job_id, reason) => {
- write!(f, "ExecutorLost : job_id={job_id}, reason:[{reason:?}].")
+ QueryStageSchedulerEvent::ExecutorLost(executor_id, reason) => {
+ write!(
+ f,
+ "ExecutorLost : executor_id={executor_id}, reason:[{reason:?}]."
+ )
}
QueryStageSchedulerEvent::CancelTasks(status) => {
write!(f, "CancelTasks : status:[{status:?}].")