[
https://issues.apache.org/jira/browse/FLINK-2748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels closed FLINK-2748.
-------------------------------------
Resolution: Fixed
Fix Version/s: 0.10
Fixed via {{19fd5bd0386e69da14f2ae24fee0aba8e34f3ce0}}.
> Accumulator fetch failure leads to duplicate job result response
> ----------------------------------------------------------------
>
> Key: FLINK-2748
> URL: https://issues.apache.org/jira/browse/FLINK-2748
> Project: Flink
> Issue Type: Bug
> Components: JobManager
> Affects Versions: master
> Reporter: Ufuk Celebi
> Assignee: Maximilian Michels
> Fix For: 0.10
>
>
> On {{JobStatusChanged}} message and a failure to catch the accumulator result
> the client will receive a {{JobResultFailure}} and {{JobResultSuccess}}
> response
> {code}
> newJobStatus match {
> case JobStatus.FINISHED =>
> val accumulatorResults: java.util.Map[String, SerializedValue[AnyRef]] =
> try {
> executionGraph.getAccumulatorsSerialized()
> } catch {
> case e: Exception =>
> log.error(s"Cannot fetch final accumulators for job $jobID", e)
> val exception = new JobExecutionException(jobID,
> "Failed to retrieve accumulator results.", e)
> jobInfo.client ! decorateMessage(JobResultFailure(
> new SerializedThrowable(exception)))
> Collections.emptyMap() <<< HERE
> }
> val result = new SerializedJobExecutionResult(
> jobID,
> jobInfo.duration,
> accumulatorResults)
> jobInfo.client ! decorateMessage(JobResultSuccess(result)) <<< HERE
> {code}
> Furthermore the indentation is off.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
