You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/09/23 16:34:04 UTC
[jira] [Created] (FLINK-2748) Accumulator fetch failure leads to
duplicate job result response
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)