[
https://issues.apache.org/jira/browse/FLINK-8269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-8269.
--------------------------------
Resolution: Implemented
Fixed by 8f9dbeca8bbb8f74bc17410b2f39903ea1f95af1
> Set netRuntime in JobExecutionResult
> ------------------------------------
>
> Key: FLINK-8269
> URL: https://issues.apache.org/jira/browse/FLINK-8269
> Project: Flink
> Issue Type: Bug
> Components: Job-Submission
> Affects Versions: 1.5.0
> Environment: 917fbcbee4599c1d198a4c63942fe1d2762aa64a
> Reporter: Gary Yao
> Assignee: Gary Yao
> Priority: Blocker
> Labels: flip-6
> Fix For: 1.5.0
>
>
> In FLIP-6 mode, the {{JobMaster}} does not correctly set the field
> {{netRuntime}} on the {{JobExecutionResult}} when the job status transitions
> to {{_FINISHED_}}.
> Find the code in question below:
> {code}
> case FINISHED:
> try {
> // TODO get correct job duration
> // job done, let's get the accumulators
> Map<String, Object> accumulatorResults =
> executionGraph.getAccumulators();
> JobExecutionResult result = new JobExecutionResult(jobID, 0L,
> accumulatorResults);
>
> executor.execute(() ->
> jobCompletionActions.jobFinished(result));
> }
> {code}
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
