[
https://issues.apache.org/jira/browse/TEZ-3697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15997321#comment-15997321
]
Zhiyuan Yang commented on TEZ-3697:
-----------------------------------
Thanks [~sseth] for review! I've uploaded new patch to address your comments.
The explicit check is because we are trying to find VMEvent returned by
writer's close() method which doesn't have VMEvent in case of pipeline shuffle.
Also I don't think it's necessary to add test specific for pipeline shuffle
because we are just verifying VMEvent's content no matter where it come from.
> Adding #output_record in vertex manager event payload
> -----------------------------------------------------
>
> Key: TEZ-3697
> URL: https://issues.apache.org/jira/browse/TEZ-3697
> Project: Apache Tez
> Issue Type: Bug
> Reporter: Zhiyuan Yang
> Assignee: Zhiyuan Yang
> Attachments: TEZ-3697.1.patch, TEZ-3697.2.patch, TEZ-3697.3.patch
>
>
> This enables estimation of total number of records generated by source
> vertex. The overhead is one more integer per payload.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
