flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Ufuk Celebi (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-2748) Accumulator fetch failure leads to duplicate job result response
Date Wed, 23 Sep 2015 14:34:04 GMT
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

newJobStatus match {
  case JobStatus.FINISHED =>
    val accumulatorResults: java.util.Map[String, SerializedValue[AnyRef]] = try {
    } 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(
    jobInfo.client ! decorateMessage(JobResultSuccess(result)) <<< HERE

Furthermore the indentation is off.

This message was sent by Atlassian JIRA

View raw message