[
https://issues.apache.org/jira/browse/FLINK-17295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17539914#comment-17539914
]
Zhu Zhu edited comment on FLINK-17295 at 5/20/22 4:31 AM:
----------------------------------------------------------
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 measured execution time is from deploying started to job
finishes (to exclude container allocation time to stabilize the result).
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.
was (Author: zhuzh):
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)
