Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
  • Loading branch information
924060929 committed Oct 17, 2024
1 parent 6affdf9 commit a5189de
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -157,7 +157,7 @@ private static Map<DistributedPlanWorker, TPipelineFragmentParamsList> plansToTh
}

private static ListMultimap<DistributedPlanWorker, AssignedJob>
groupInstancePerWorker(PipelineDistributedPlan fragmentPlan) {
groupInstancePerWorker(PipelineDistributedPlan fragmentPlan) {
ListMultimap<DistributedPlanWorker, AssignedJob> workerToInstances = ArrayListMultimap.create();
for (AssignedJob instanceJob : fragmentPlan.getInstanceJobs()) {
workerToInstances.put(instanceJob.getAssignedWorker(), instanceJob);
Expand Down

0 comments on commit a5189de

Please sign in to comment.