pub fn build_graph(
plan_node: PlanRef,
job_type: Option<GraphJobType>,
) -> Result<StreamFragmentGraph, SchedulerError>
pub fn build_graph(
plan_node: PlanRef,
job_type: Option<GraphJobType>,
) -> Result<StreamFragmentGraph, SchedulerError>