Skip to content

Commit 9cb8ed1

Browse files
thinkharderdevfsdvh
authored andcommitted
Fix job submitted metric by ignoring resubmissions
1 parent 2a83817 commit 9cb8ed1

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

ballista/scheduler/src/scheduler_server/query_stage_scheduler.rs

+2
Original file line numberDiff line numberDiff line change
@@ -183,6 +183,8 @@ impl<T: 'static + AsLogicalPlan, U: 'static + AsExecutionPlan>
183183
tokio::task::spawn(async move {
184184
tokio::time::sleep(Duration::from_millis(wait_ms)).await;
185185

186+
tokio::task::spawn(async move {
187+
tokio::time::sleep(Duration::from_millis(200)).await;
186188
if let Err(e) = tx_event
187189
.post_event(QueryStageSchedulerEvent::JobSubmitted {
188190
job_id,

0 commit comments

Comments
 (0)