Minor fix

Ted-Jiang · Jul 26, 2022 · 784b04f · 784b04f
1 parent 1075541
commit 784b04f
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/ballista/rust/scheduler/src/planner.rs b/ballista/rust/scheduler/src/planner.rs
@@ -74,6 +74,7 @@ impl DistributedPlanner {
             new_plan,
             None,
         )?);
+        info!("finished planning");
         Ok(stages)
     }
 

diff --git a/ballista/rust/scheduler/src/scheduler_server/mod.rs b/ballista/rust/scheduler/src/scheduler_server/mod.rs
@@ -191,7 +191,7 @@ impl<T: 'static + AsLogicalPlan, U: 'static + AsExecutionPlan> SchedulerServer<T
                 .unwrap_or_else(|| addr),
             port: executor_metadata.port as u16,
             grpc_port: executor_metadata.grpc_port as u16,
-            specification: executor_metadata.specification.unwrap().clone().into(),
+            specification: executor_metadata.specification.unwrap().into(),
         };
         // save the metadata to cache
         self.state.save_executor_metadata(metadata.clone()).await?;
-Original file line number
+Diff line change
@@ Expand Up / @@ -74,6 +74,7 @@ impl DistributedPlanner { @@
                 new_plan,
                 None,
             )?);
+            info!("finished planning");
             Ok(stages)
         }
@@ Expand Down @@