Ufuk Celebi created FLINK-2748:
----------------------------------
Summary: 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
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)
