Minor refactor in SqlQueryScheduler
create objects in input argument order
@@ -440,6 +440,7 @@ public class SqlQueryScheduler
}
});
+ StageLinkage stageLinkage = new StageLinkage(fragmentId, parent, childStageExecutions);
StageScheduler stageScheduler = createStageScheduler(
plan,
nodeScheduler,
@@ -455,7 +456,6 @@ public class SqlQueryScheduler
splitSourceFactory,
tableWriteInfo,
childStageExecutions);
- StageLinkage stageLinkage = new StageLinkage(fragmentId, parent, childStageExecutions);
stageExecutionInfos.add(new StageExecutionAndScheduler(stageExecution, stageLinkage, stageScheduler));
return stageExecutionInfos.build();
