flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Gary Yao (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-8269) Set netRuntime in JobExecutionResult
Date Fri, 15 Dec 2017 15:29:00 GMT
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)

Mime
View raw message