[
https://issues.apache.org/jira/browse/FLINK-8269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao reassigned FLINK-8269:
-------------------------------
Assignee: Gary Yao
> 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
>
> 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
(v6.4.14#64029)
