Gary Yao created FLINK-8269:
-------------------------------
Summary: 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
Priority: Blocker
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)
