Skip to content

Commit

Permalink
change non_heap to nonheap
Browse files Browse the repository at this point in the history
  • Loading branch information
JonathanWamsley committed Jun 1, 2022
1 parent 57f27c7 commit 681ed51
Show file tree
Hide file tree
Showing 10 changed files with 930 additions and 930 deletions.
6 changes: 3 additions & 3 deletions receiver/flinkmetricsreceiver/documentation.md
Original file line number Diff line number Diff line change
Expand Up @@ -28,9 +28,9 @@ These are the metrics available for this scraper.
| **flink.jvm.memory.metaspace.committed** | The amount of memory guaranteed to be available to the JVM in the Metaspace memory pool. | By | Sum(Int) | <ul> </ul> |
| **flink.jvm.memory.metaspace.max** | The maximum amount of memory that can be used in the Metaspace memory pool. | By | Sum(Int) | <ul> </ul> |
| **flink.jvm.memory.metaspace.used** | The amount of memory currently used in the Metaspace memory pool. | By | Sum(Int) | <ul> </ul> |
| **flink.jvm.memory.non_heap.committed** | The amount of non-heap memory guaranteed to be available to the JVM. | By | Sum(Int) | <ul> </ul> |
| **flink.jvm.memory.non_heap.max** | The maximum amount of non-heap memory that can be used for memory management. | By | Sum(Int) | <ul> </ul> |
| **flink.jvm.memory.non_heap.used** | The amount of non-heap memory currently used. | By | Sum(Int) | <ul> </ul> |
| **flink.jvm.memory.nonheap.committed** | The amount of non-heap memory guaranteed to be available to the JVM. | By | Sum(Int) | <ul> </ul> |
| **flink.jvm.memory.nonheap.max** | The maximum amount of non-heap memory that can be used for memory management. | By | Sum(Int) | <ul> </ul> |
| **flink.jvm.memory.nonheap.used** | The amount of non-heap memory currently used. | By | Sum(Int) | <ul> </ul> |
| **flink.jvm.threads.count** | The total number of live threads. | {threads} | Sum(Int) | <ul> </ul> |
| **flink.memory.managed.total** | The total amount of managed memory. | By | Sum(Int) | <ul> </ul> |
| **flink.memory.managed.used** | The amount of managed memory currently used. | By | Sum(Int) | <ul> </ul> |
Expand Down

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

6 changes: 3 additions & 3 deletions receiver/flinkmetricsreceiver/metadata.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -88,7 +88,7 @@ metrics:
value_type: int
input_type: string
attributes: []
flink.jvm.memory.non_heap.used:
flink.jvm.memory.nonheap.used:
enabled: true
description: The amount of non-heap memory currently used.
unit: By
Expand All @@ -98,7 +98,7 @@ metrics:
value_type: int
input_type: string
attributes: []
flink.jvm.memory.non_heap.committed:
flink.jvm.memory.nonheap.committed:
enabled: true
description: The amount of non-heap memory guaranteed to be available to the JVM.
unit: By
Expand All @@ -108,7 +108,7 @@ metrics:
value_type: int
input_type: string
attributes: []
flink.jvm.memory.non_heap.max:
flink.jvm.memory.nonheap.max:
enabled: true
description: The maximum amount of non-heap memory that can be used for memory management.
unit: By
Expand Down
12 changes: 6 additions & 6 deletions receiver/flinkmetricsreceiver/process.go
Original file line number Diff line number Diff line change
Expand Up @@ -53,11 +53,11 @@ func (s *flinkmetricsScraper) processJobmanagerMetrics(now pcommon.Timestamp, jo
case "Status.JVM.Memory.Metaspace.Committed":
_ = s.mb.RecordFlinkJvmMemoryMetaspaceCommittedDataPoint(now, metric.Value)
case "Status.JVM.Memory.NonHeap.Max":
_ = s.mb.RecordFlinkJvmMemoryNonHeapMaxDataPoint(now, metric.Value)
_ = s.mb.RecordFlinkJvmMemoryNonheapMaxDataPoint(now, metric.Value)
case "Status.JVM.Memory.NonHeap.Committed":
_ = s.mb.RecordFlinkJvmMemoryNonHeapCommittedDataPoint(now, metric.Value)
_ = s.mb.RecordFlinkJvmMemoryNonheapCommittedDataPoint(now, metric.Value)
case "Status.JVM.Memory.NonHeap.Used":
_ = s.mb.RecordFlinkJvmMemoryNonHeapUsedDataPoint(now, metric.Value)
_ = s.mb.RecordFlinkJvmMemoryNonheapUsedDataPoint(now, metric.Value)
case "Status.JVM.Memory.Metaspace.Max":
_ = s.mb.RecordFlinkJvmMemoryMetaspaceMaxDataPoint(now, metric.Value)
case "Status.JVM.Memory.Direct.MemoryUsed":
Expand Down Expand Up @@ -111,11 +111,11 @@ func (s *flinkmetricsScraper) processTaskmanagerMetrics(now pcommon.Timestamp, t
case "Status.JVM.Memory.Metaspace.Committed":
_ = s.mb.RecordFlinkJvmMemoryMetaspaceCommittedDataPoint(now, metric.Value)
case "Status.JVM.Memory.NonHeap.Max":
_ = s.mb.RecordFlinkJvmMemoryNonHeapMaxDataPoint(now, metric.Value)
_ = s.mb.RecordFlinkJvmMemoryNonheapMaxDataPoint(now, metric.Value)
case "Status.JVM.Memory.NonHeap.Committed":
_ = s.mb.RecordFlinkJvmMemoryNonHeapCommittedDataPoint(now, metric.Value)
_ = s.mb.RecordFlinkJvmMemoryNonheapCommittedDataPoint(now, metric.Value)
case "Status.JVM.Memory.NonHeap.Used":
_ = s.mb.RecordFlinkJvmMemoryNonHeapUsedDataPoint(now, metric.Value)
_ = s.mb.RecordFlinkJvmMemoryNonheapUsedDataPoint(now, metric.Value)
case "Status.JVM.Memory.Metaspace.Max":
_ = s.mb.RecordFlinkJvmMemoryMetaspaceMaxDataPoint(now, metric.Value)
case "Status.JVM.Memory.Direct.MemoryUsed":
Expand Down
Loading

0 comments on commit 681ed51

Please sign in to comment.