[ 
https://issues.apache.org/jira/browse/FLINK-14435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

lining updated FLINK-14435:
---------------------------
    Description: 
data in json
{
  "cpuAllocated": -1,
  "cpuUsage": -1,
  "taskHeapAllocated": 966787072,
  "taskHeapUsed": 76071880,
  "heapManageMemoryMax": 0,
  "heapManageMemoryUsed": 0,
  "offHeapManageMemoryMax": 0,
  "offHeapManageMemoryUsed": 0,
  "networkMemoryMax": 107413504,
  "networkMemoryUsed": 0
}
merge information to match Taskmanager’s memory composition
public static TaskManagerResourceInfo create(HardwareDescription 
hardwareDescription, TaskManagerMetricsInfo taskManagerMetrics, 
TaskManagerResourceConfig taskManagerResourceConfig) {
        long javaHeapAllocated = taskManagerMetrics.getHeapCommitted();
        long javaHeapUsed = taskManagerMetrics.getHeapUsed();
        long pageSize = taskManagerResourceConfig.getSizeOfMemorySegment();
        long heapManageMemoryAllocated = 0L;
        long heapManageMemoryUsed = 0L;
        long offHeapManageMemoryAllocated = 0L;
        long offHeapManageMemoryUsed = 0L;
        long networkMemoryAllocated = 
taskManagerMetrics.getMemorySegmentsTotal() * pageSize;
        long networkMemoryUsed = (taskManagerMetrics.getMemorySegmentsTotal() - 
taskManagerMetrics.getMemorySegmentsAvailable()) * pageSize;
        long manageMemoryAllocated = 
taskManagerMetrics.getManageMemorySegmentsTotal() * pageSize;
        long manageMemoryUsed = 
(taskManagerMetrics.getManageMemorySegmentsTotal() - 
taskManagerMetrics.getManageMemorySegmentsAvailable()) * pageSize;

       
if(taskManagerResourceConfig.getManagedMemoryType().equalsIgnoreCase(MemoryType.HEAP.name(){
            heapManageMemoryAllocated = manageMemoryAllocated;
            heapManageMemoryUsed = manageMemoryUsed;
            javaHeapAllocated = javaHeapAllocated - heapManageMemoryAllocated;
            javaHeapUsed = taskManagerMetrics.getHeapUsed() - 
heapManageMemoryUsed;
        } else {
            offHeapManageMemoryAllocated = manageMemoryAllocated;
            offHeapManageMemoryUsed = manageMemoryUsed;
        }
        return new TaskManagerResourceInfo(-1.0d, -1.0d, javaHeapAllocated, 
javaHeapUsed, 
             heapManageMemoryAllocated, heapManageMemoryUsed, 
offHeapManageMemoryAllocated, 
             offHeapManageMemoryUsed, networkMemoryAllocated, 
networkMemoryUsed);
}
cpuAllocated depend on flip-49 (TaskExecutorResourceSpec)
cpuUsage = (metric Status.JVM.CPU.Loadfrom) * cpuAllocated

> Add TaskManagerResourceInfo in TaskManagerDetailsInfo to show TaskManager 
> Resource
> ----------------------------------------------------------------------------------
>
>                 Key: FLINK-14435
>                 URL: https://issues.apache.org/jira/browse/FLINK-14435
>             Project: Flink
>          Issue Type: Sub-task
>          Components: Runtime / REST
>            Reporter: lining
>            Priority: Major
>
> data in json
> {
>   "cpuAllocated": -1,
>   "cpuUsage": -1,
>   "taskHeapAllocated": 966787072,
>   "taskHeapUsed": 76071880,
>   "heapManageMemoryMax": 0,
>   "heapManageMemoryUsed": 0,
>   "offHeapManageMemoryMax": 0,
>   "offHeapManageMemoryUsed": 0,
>   "networkMemoryMax": 107413504,
>   "networkMemoryUsed": 0
> }
> merge information to match Taskmanager’s memory composition
> public static TaskManagerResourceInfo create(HardwareDescription 
> hardwareDescription, TaskManagerMetricsInfo taskManagerMetrics, 
> TaskManagerResourceConfig taskManagerResourceConfig) {
>         long javaHeapAllocated = taskManagerMetrics.getHeapCommitted();
>         long javaHeapUsed = taskManagerMetrics.getHeapUsed();
>         long pageSize = taskManagerResourceConfig.getSizeOfMemorySegment();
>         long heapManageMemoryAllocated = 0L;
>         long heapManageMemoryUsed = 0L;
>         long offHeapManageMemoryAllocated = 0L;
>         long offHeapManageMemoryUsed = 0L;
>         long networkMemoryAllocated = 
> taskManagerMetrics.getMemorySegmentsTotal() * pageSize;
>         long networkMemoryUsed = (taskManagerMetrics.getMemorySegmentsTotal() 
> - taskManagerMetrics.getMemorySegmentsAvailable()) * pageSize;
>         long manageMemoryAllocated = 
> taskManagerMetrics.getManageMemorySegmentsTotal() * pageSize;
>         long manageMemoryUsed = 
> (taskManagerMetrics.getManageMemorySegmentsTotal() - 
> taskManagerMetrics.getManageMemorySegmentsAvailable()) * pageSize;
>        
> if(taskManagerResourceConfig.getManagedMemoryType().equalsIgnoreCase(MemoryType.HEAP.name(){
>             heapManageMemoryAllocated = manageMemoryAllocated;
>             heapManageMemoryUsed = manageMemoryUsed;
>             javaHeapAllocated = javaHeapAllocated - heapManageMemoryAllocated;
>             javaHeapUsed = taskManagerMetrics.getHeapUsed() - 
> heapManageMemoryUsed;
>         } else {
>             offHeapManageMemoryAllocated = manageMemoryAllocated;
>             offHeapManageMemoryUsed = manageMemoryUsed;
>         }
>         return new TaskManagerResourceInfo(-1.0d, -1.0d, javaHeapAllocated, 
> javaHeapUsed, 
>              heapManageMemoryAllocated, heapManageMemoryUsed, 
> offHeapManageMemoryAllocated, 
>              offHeapManageMemoryUsed, networkMemoryAllocated, 
> networkMemoryUsed);
> }
> cpuAllocated depend on flip-49 (TaskExecutorResourceSpec)
> cpuUsage = (metric Status.JVM.CPU.Loadfrom) * cpuAllocated



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to