[jira] [Created] (FLINK-5103) Process virtual memory and physical memory used size gauge
zhuhaifeng created FLINK-5103: - Summary: Process virtual memory and physical memory used size gauge Key: FLINK-5103 URL: https://issues.apache.org/jira/browse/FLINK-5103 Project: Flink Issue Type: Improvement Reporter: zhuhaifeng Assignee: zhuhaifeng Priority: Minor Fix For: 1.2.0 Add TaskManger Process virtual memory and physical memory used size gauge metrics. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (FLINK-5069) Pending checkpoint statistics gauge
zhuhaifeng created FLINK-5069: - Summary: Pending checkpoint statistics gauge Key: FLINK-5069 URL: https://issues.apache.org/jira/browse/FLINK-5069 Project: Flink Issue Type: Improvement Reporter: zhuhaifeng Assignee: zhuhaifeng Priority: Minor Fix For: 1.2.0 Add the statistics of pending checkpoints as a gauge metric. When the checkpoint appears not to be completed, this metric would help to get the state of a pending checkpoint , e.g which task did not complete the checkpoint. The statistic will be as the follows: checkpointID, Number Of Acknowledged Tasks, Number Of Not yet Acknowledged Tasks, The detail of not yet acknowledged JobVertexID, taskID -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (FLINK-4923) Expose input/output queued buffers and buffer usage as a metric for a Task
zhuhaifeng created FLINK-4923: - Summary: Expose input/output queued buffers and buffer usage as a metric for a Task Key: FLINK-4923 URL: https://issues.apache.org/jira/browse/FLINK-4923 Project: Flink Issue Type: Improvement Reporter: zhuhaifeng Priority: Minor Fix For: 1.2.0 We should expose the following Metrics on the TaskIOMetricGroup: 1. numInputQueuedBuffers: received buffers of InputGates for a task 2. numOutputQueuedBuffers: buffers of produced ResultPartitions for a task 3. InputQueueUsage: usage of InputGates buffer pool for a task 4. OutputQueueUsage: usage of produced ResultPartitions buffer pool for a task -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (FLINK-4840) Introduce an OperatorSystemMetricGroup
zhuhaifeng created FLINK-4840: - Summary: Introduce an OperatorSystemMetricGroup Key: FLINK-4840 URL: https://issues.apache.org/jira/browse/FLINK-4840 Project: Flink Issue Type: Improvement Components: Metrics Reporter: zhuhaifeng Priority: Minor Fix For: 1.2.0 There will introduces the OperatorSystemMetricGroup, which encapsulates the insantiation of TPS meter, lantency/proc_time_cost histograms. Operator related System metrics are not instantiated directly by the specific Operator, but instead within the OperatorSystemMetricGroup contained in the respective OperatorMetricGroup. They are then later accessed by relevant components(maybe different places), instead of instantiated them identically with static name constants. Other system scope metrics (maybe delay/queue_in/queue_out) can add into the OperatorSystemMetricGroup some later. -- This message was sent by Atlassian JIRA (v6.3.4#6332)