Remove outdated comment in SourcePartitionedScheduler#assignSplits
This comments was added in
when partition id has to be explicitly specified when creating task.
At that time BROADCAST_PARTITION_ID is used for partition id.
Task creation doesn't require partition id for a long time. This comment
only cause confusion when reading the code.
@@ -437,7 +437,6 @@ public class SourcePartitionedScheduler
.addAll(noMoreSplitsNotification.keySet())
.build();
for (InternalNode node : nodes) {
- // source partitioned tasks can only receive broadcast data; otherwise it would have a different distribution
ImmutableMultimap<PlanNodeId, Split> splits = ImmutableMultimap.<PlanNodeId, Split>builder()
.putAll(partitionedNode, splitAssignment.get(node))
.build();
