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 8c49b929 Remove duplicate remove_active_execution_graph when merge PR
393
8c49b929 is described below
commit 8c49b929fd6fe8f3da5b0349aaf3ff8fec59e013
Author: yangzhong <[email protected]>
AuthorDate: Thu Oct 20 06:18:48 2022 +0800
Remove duplicate remove_active_execution_graph when merge PR 393
---
ballista/scheduler/src/state/task_manager.rs | 8 --------
1 file changed, 8 deletions(-)
diff --git a/ballista/scheduler/src/state/task_manager.rs
b/ballista/scheduler/src/state/task_manager.rs
index 77b74495..841c5421 100644
--- a/ballista/scheduler/src/state/task_manager.rs
+++ b/ballista/scheduler/src/state/task_manager.rs
@@ -643,14 +643,6 @@ impl<T: 'static + AsLogicalPlan, U: 'static +
AsExecutionPlan> TaskManager<T, U>
.map(|value| value.1.execution_graph)
}
- /// Remove the `ExecutionGraph` for the given job ID from cache
- pub(crate) async fn remove_active_execution_graph(
- &self,
- job_id: &str,
- ) -> Option<Arc<RwLock<ExecutionGraph>>> {
- self.active_job_cache.remove(job_id).map(|value| value.1)
- }
-
/// Get the `ExecutionGraph` for the given job ID. This will search fist
in the `ActiveJobs`
/// keyspace and then, if it doesn't find anything, search the
`CompletedJobs` keyspace.
pub(crate) async fn get_execution_graph(
