Skip to content

Commit

Permalink
add check
Browse files Browse the repository at this point in the history
  • Loading branch information
924060929 committed Oct 18, 2024
1 parent 196d34c commit ace47a4
Showing 1 changed file with 1 addition and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -41,6 +41,7 @@ public class PipelineDistributedPlan extends DistributedPlan {
// current, we only support all instances of the same fragment reuse the same destination
private Map<DataSink, List<AssignedJob>> destinations;

/** constructor */
public PipelineDistributedPlan(
UnassignedJob fragmentJob,
List<AssignedJob> instanceJobs,
Expand Down

0 comments on commit ace47a4

Please sign in to comment.