Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-2223

Web frontend shows wrong accumulator results for latest job

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Closed
    • Minor
    • Resolution: Invalid
    • None
    • None
    • None
    • None

    Description

      The web frontend always displays for the latest finished job in the history that it has an accumulator with name JobID (SerializedListAccumulator) and value org.apache.flink.api.common.accumulators.SerializedListAccumulator. This seems to an artifact of the way we send accumulators via akka. Maybe the SerializedListAccumulator is always collected in the JobManager's AccumulatorManager no matter whether the job used accumulators or not. Then, this accumulator is returned to the web frontend as long as no other job was started.

      Attachments

        Activity

          People

            Unassigned Unassigned
            trohrmann Till Rohrmann
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: