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

Update suspended ExecutionGraph to lower latency

    Details

    • Type: Bug
    • Status: Closed
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: 1.3.0
    • Component/s: Webfrontend
    • Labels:
      None

      Description

      Now in ExecutionGraphHolder, which is used in many handlers, we use a WeakHashMap to cache ExecutionGraph(s), which is only sensitive to garbage collection.

      The latency is too high when JVM do GC rarely, which will make status of jobs or its tasks unmatched with the real ones.

      LoadingCache is a common used cache implementation from guava lib, we can use its time based eviction to lower latency of status update.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                WangTao Tao Wang
                Reporter:
                WangTao Tao Wang
              • Votes:
                0 Vote for this issue
                Watchers:
                3 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: