[ 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)