[
https://issues.apache.org/jira/browse/FLINK-17295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17539914#comment-17539914
]
Zhu Zhu commented on FLINK-17295:
---------------------------------
I was not concerning about it because PartitionRequests are sent and processed
by TMs in a distributed way, unlike TDD shipping which relies on the master
node.
To further eliminating concerns, I did an experiment to see the job execution
time with/without the proposed change. The testing job is a word count job of
no data, parallelism=1000, run 3 times for each case. The average execution
time with the change is 7.4s (7.6,7.5,7.0). The average execution time without
the change is 7.9s(8.7,6.9,8.0). Therefore, I think the change is acceptable.
> Refactor the ExecutionAttemptID to consist of ExecutionVertexID and
> attemptNumber
> ---------------------------------------------------------------------------------
>
> Key: FLINK-17295
> URL: https://issues.apache.org/jira/browse/FLINK-17295
> Project: Flink
> Issue Type: Sub-task
> Components: Runtime / Coordination
> Reporter: Yangze Guo
> Assignee: Zhu Zhu
> Priority: Major
> Labels: pull-request-available
>
> Make the ExecutionAttemptID being composed of (ExecutionVertexID,
> attemptNumber).
--
This message was sent by Atlassian Jira
(v8.20.7#820007)
