[FLINK-8269] Set netRuntime in JobExecutionResult

• Type: Bug
• Status: Closed
• Priority: Blocker
• Resolution: Implemented
• Affects Version/s: 1.5.0
• Fix Version/s: 1.5.0
• Component/s: Runtime / Coordination
• Labels: flip-6

Environment

917fbcbee4599c1d198a4c63942fe1d2762aa64a

• Assignee: Gary Yao
• Reporter: Gary Yao
• Created: 15/Dec/17 15:28
• Updated: 28/Feb/19 13:30
• Resolved: 29/Mar/18 13:59

Description

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:

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));
	}