flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Tao Wang (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-6295) use LoadingCache instead of WeakHashMap to lower latency
Date Tue, 11 Apr 2017 11:38:41 GMT
Tao Wang created FLINK-6295:
-------------------------------

             Summary: use LoadingCache instead of WeakHashMap to lower latency
                 Key: FLINK-6295
                 URL: https://issues.apache.org/jira/browse/FLINK-6295
             Project: Flink
          Issue Type: Bug
          Components: Webfrontend
            Reporter: Tao Wang


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.



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

Mime
View raw message