You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/03/05 09:03:00 UTC
[jira] [Updated] (FLINK-8269) Set netRuntime in JobExecutionResult
[ https://issues.apache.org/jira/browse/FLINK-8269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Aljoscha Krettek updated FLINK-8269:
------------------------------------
Fix Version/s: 1.5.0
> 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)