Andrey Zagrebin created FLINK-12110:
---------------------------------------

             Summary: Introduce API point for ShuffleService to get estimation 
of locally required memory
                 Key: FLINK-12110
                 URL: https://issues.apache.org/jira/browse/FLINK-12110
             Project: Flink
          Issue Type: Sub-task
          Components: Runtime / Network
            Reporter: Andrey Zagrebin
            Assignee: zhijiang


At the moment, we use static method TaskManagerServices.calculateHeapSizeMB to 
estimate local memory needed in TM container for network environment. As 
network environment becomes pluggable shuffle service, we should also make this 
request from container to shuffle service pluggable.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Reply via email to