This is an automated email from the ASF dual-hosted git repository.
nju_yaho pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/arrow-ballista.git
The following commit(s) were added to refs/heads/master by this push:
new 02ed1367 Fix scheduler_name format for executor report task status in
push-staged mode (#217)
02ed1367 is described below
commit 02ed136700830a85f1a7b05b1f344368ddae1c7b
Author: r.4ntix <[email protected]>
AuthorDate: Thu Sep 15 21:53:07 2022 +0800
Fix scheduler_name format for executor report task status in push-staged
mode (#217)
---
ballista/rust/scheduler/src/main.rs | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
diff --git a/ballista/rust/scheduler/src/main.rs
b/ballista/rust/scheduler/src/main.rs
index be8acfc7..7aa7a756 100644
--- a/ballista/rust/scheduler/src/main.rs
+++ b/ballista/rust/scheduler/src/main.rs
@@ -168,11 +168,13 @@ async fn main() -> Result<()> {
let port = opt.bind_port;
let log_dir = opt.log_dir;
let print_thread_info = opt.print_thread_info;
- let scheduler_name = format!("scheduler_{}_{}_{}", namespace,
external_host, port);
+ let log_file_name_prefix =
+ format!("scheduler_{}_{}_{}", namespace, external_host, port);
+ let scheduler_name = format!("{}:{}", external_host, port);
// File layer
if let Some(log_dir) = log_dir {
- let log_file = tracing_appender::rolling::daily(log_dir,
&scheduler_name);
+ let log_file = tracing_appender::rolling::daily(log_dir,
&log_file_name_prefix);
tracing_subscriber::fmt()
.with_ansi(true)
.with_thread_names(print_thread_info)
