gortiz commented on code in PR #14507:
URL: https://github.com/apache/pinot/pull/14507#discussion_r1888278250
##########
pinot-query-planner/src/main/java/org/apache/pinot/query/planner/physical/MailboxAssignmentVisitor.java:
##########
@@ -43,99 +43,102 @@ public Void process(PlanNode node, DispatchablePlanContext
context) {
if (node instanceof MailboxSendNode) {
MailboxSendNode sendNode = (MailboxSendNode) node;
int senderStageId = sendNode.getStageId();
- int receiverStageId = sendNode.getReceiverStageId();
- Map<Integer, DispatchablePlanMetadata> metadataMap =
context.getDispatchablePlanMetadataMap();
- DispatchablePlanMetadata senderMetadata = metadataMap.get(senderStageId);
- DispatchablePlanMetadata receiverMetadata =
metadataMap.get(receiverStageId);
- Map<Integer, QueryServerInstance> senderServerMap =
senderMetadata.getWorkerIdToServerInstanceMap();
- Map<Integer, QueryServerInstance> receiverServerMap =
receiverMetadata.getWorkerIdToServerInstanceMap();
- Map<Integer, Map<Integer, MailboxInfos>> senderMailboxesMap =
senderMetadata.getWorkerIdToMailboxesMap();
- Map<Integer, Map<Integer, MailboxInfos>> receiverMailboxesMap =
receiverMetadata.getWorkerIdToMailboxesMap();
+ for (Integer receiverStageId : sendNode.getReceiverStageIds()) {
Review Comment:
I recommend to review this class with the `hide whitespace` option in GH
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
