diff --git a/Makefile.toml b/Makefile.toml index 92b65271b8d3c..bd37dca322e2f 100644 --- a/Makefile.toml +++ b/Makefile.toml @@ -105,7 +105,7 @@ do fi done -if (( "$(du -sk ${PREFIX_LOG} | cut -f1)" > 4000 )) ; then +if (( "$(du -sk ${PREFIX_LOG} | cut -f1)" > 2000 )) ; then echo "$(tput setaf 3)log size is significantly large ($(du -sh ${PREFIX_LOG} | cut -f1)).$(tput sgr0) Please disable unnecessary logs." exit 1 fi diff --git a/src/batch/src/rpc/service/task_service.rs b/src/batch/src/rpc/service/task_service.rs index b054481833976..229873a71b1ee 100644 --- a/src/batch/src/rpc/service/task_service.rs +++ b/src/batch/src/rpc/service/task_service.rs @@ -125,9 +125,10 @@ impl TaskService for BatchServiceImpl { let plan = req.get_plan().expect("no plan found").clone(); let epoch = req.epoch; let context = ComputeNodeContext::new(self.env.clone()); - debug!( + trace!( "local execute request: plan:{:?} with task id:{:?}", - plan, task_id + plan, + task_id ); let task = BatchTaskExecution::new(task_id, plan, context, epoch)?; let task = Arc::new(task); diff --git a/src/batch/src/task/task_execution.rs b/src/batch/src/task/task_execution.rs index b14b77f87e050..d3b268c0b9766 100644 --- a/src/batch/src/task/task_execution.rs +++ b/src/batch/src/task/task_execution.rs @@ -293,7 +293,7 @@ impl BatchTaskExecution { sender.send(Some(data_chunk?)).await?; } None => { - debug!("data chunk stream shuts down"); + trace!("data chunk stream shuts down"); sender.send(None).await?; break; }