flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Gary Yao (JIRA)" <j...@apache.org>
Subject [jira] [Assigned] (FLINK-8269) Set netRuntime in JobExecutionResult
Date Tue, 02 Jan 2018 10:00:00 GMT

     [ 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)

Mime
View raw message