[jira] [Created] (FLINK-5103) Process virtual memory and physical memory used size gauge

2016-11-18 Thread zhuhaifeng (JIRA)
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

2016-11-15 Thread zhuhaifeng (JIRA)
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

2016-10-25 Thread zhuhaifeng (JIRA)
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

2016-10-17 Thread zhuhaifeng (JIRA)
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)