Weihua Hu created FLINK-32386:
---------------------------------
Summary: Add ShuffleDescriptorsCache in TaskExecutor to cache
ShuffleDescriptors
Key: FLINK-32386
URL: https://issues.apache.org/jira/browse/FLINK-32386
Project: Flink
Issue Type: Sub-task
Components: Runtime / Coordination
Reporter: Weihua Hu
Introduce a new struct named ShuffleDescriptorsCache to cache
ShuffleDescriptorAndIndex which are offloaded by the blob server.
The cache should have the following capabilities:
1. Expired after exceeding the TTL.
2. Limit the size of the cache. Remove the oldest element from the cache when
its maximum size has been exceeded.
3. Clear elements belong to a job when it disconnects from TaskExecutor.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
