OpenTelemetry Bot d680729c09 [chore] Prepare release 0.90.0 (#29543) 1 rok temu
..
internal 91643ba261 [mdatagen] allow adding resource_attribute warnings (#27257) 1 rok temu
testdata cd91fb4789 [chore][golden] Normal timestamps in golden metric files (#23002) 1 rok temu
Makefile c135dab0b3 [receiver/Flinkmetricsreceiver] Apache Flink Metric Receiver (#10121) 2 lat temu
README.md 0bcaca9a37 [chore] update codeowners to respect capitalization (#25848) 1 rok temu
client.go b44e8d0b12 [chore] prealloc slice (#24966) 1 rok temu
client_test.go 5133f4ccd6 [chore] use license shortform (#22052) 1 rok temu
config.go 5133f4ccd6 [chore] use license shortform (#22052) 1 rok temu
config_test.go 158ee0e040 [chore] Update tests to include scraper settings (#24653) 1 rok temu
doc.go 5133f4ccd6 [chore] use license shortform (#22052) 1 rok temu
documentation.md 252b3a0c6b [chore] Metadata inconsistencies (#21915) 1 rok temu
factory.go 2c5577b0d7 [chore] updating scrapers to use default method from scraperhelper (#22138) 1 rok temu
factory_test.go 4a0ea8e961 [chore] Improving life cycle tests reporting (#23145) 1 rok temu
go.mod d680729c09 [chore] Prepare release 0.90.0 (#29543) 1 rok temu
go.sum 40b485f08a Update core for v0.90.0 release (#29539) 1 rok temu
integration_test.go bb932d1f2a [chore] [receiver/flinkmetrics] Temporarily disable integration test (#26194) 1 rok temu
metadata.yaml 0bcaca9a37 [chore] update codeowners to respect capitalization (#25848) 1 rok temu
process.go 29ea5a964d [cmd/mdatagen] Avoid reusing the same ResourceBuilder instance (#24762) 1 rok temu
scraper.go 29ea5a964d [cmd/mdatagen] Avoid reusing the same ResourceBuilder instance (#24762) 1 rok temu
scraper_test.go cd92432fd2 [pkg/golden] internal/coreinternal/golden -> pkg/golden (#28636) 1 rok temu

README.md

FlinkMetrics Receiver

Status
Stability alpha: metrics
Distributions contrib, observiq, sumo
Issues Open issues Closed issues
Code Owners @JonathanWamsley, @djaglowski

This receiver uses Flink's REST API to collect Jobmanager, Taskmanager, Job, Task and Operator metrics.

Prerequisites

This receiver supports Apache Flink versions 1.13.6 and 1.14.4.

By default, authentication is not required. However, Flink recommends using a “side car proxy” that Binds the REST endpoint to the loopback interface and to start a REST proxy that authenticates and forwards the request to Flink.

SSL can be enabled with the following REST endpoint options for external connectivity and have a self signed certificate or be self signed.

Configuration

The following settings are optional:

  • endpoint (default: http://localhost:15672): The URL of the node to be monitored.
  • collection_interval (default = 10s): This receiver collects metrics on an interval. Valid time units are ns, us (or µs), ms, s, m, h.
  • tls (defaults defined here): TLS control. By default insecure settings are rejected and certificate verification is on.
  • initial_delay (default = 1s): defines how long this receiver waits before starting.

Example Configuration

receivers:
  flinkmetrics:
    endpoint: http://localhost:8081
    collection_interval: 10s

The full list of settings exposed for this receiver are documented here with detailed sample configurations here. TLS config is documented further under the opentelemetry collector's configtls package.

Metrics

Details about the metrics produced by this receiver can be found in metadata.yaml